org.codehaus.activemq.ra
Class ActiveMQBaseEndpointWorker

java.lang.Object
  extended byorg.codehaus.activemq.ra.ActiveMQBaseEndpointWorker
Direct Known Subclasses:
ActiveMQAsfEndpointWorker, ActiveMQPollingEndpointWorker

public abstract class ActiveMQBaseEndpointWorker
extends Object

Version:
$Revision: 1.6 $ $Date: 2004/12/01 03:03:11 $

Field Summary
protected  ActiveMQResourceAdapter adapter
           
protected  ActiveMQEndpointActivationKey endpointActivationKey
           
protected  MessageEndpointFactory endpointFactory
           
static Method ON_MESSAGE_METHOD
           
protected  boolean transacted
           
protected  WorkManager workManager
           
 
Constructor Summary
ActiveMQBaseEndpointWorker(ActiveMQResourceAdapter adapter, ActiveMQEndpointActivationKey key)
           
 
Method Summary
static void safeClose(Connection c)
           
static void safeClose(ConnectionConsumer cc)
           
static void safeClose(Session s)
           
abstract  void start()
           
abstract  void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

ON_MESSAGE_METHOD

public static final Method ON_MESSAGE_METHOD

adapter

protected ActiveMQResourceAdapter adapter

endpointActivationKey

protected ActiveMQEndpointActivationKey endpointActivationKey

endpointFactory

protected MessageEndpointFactory endpointFactory

workManager

protected WorkManager workManager

transacted

protected boolean transacted
Constructor Detail

ActiveMQBaseEndpointWorker

public ActiveMQBaseEndpointWorker(ActiveMQResourceAdapter adapter,
                                  ActiveMQEndpointActivationKey key)
                           throws ResourceException
Method Detail

safeClose

public static void safeClose(Session s)
Parameters:
s -

safeClose

public static void safeClose(Connection c)
Parameters:
c -

safeClose

public static void safeClose(ConnectionConsumer cc)
Parameters:
cc -

start

public abstract void start()
                    throws WorkException,
                           ResourceException
Throws:
WorkException
ResourceException

stop

public abstract void stop()
                   throws InterruptedException
Throws:
InterruptedException


Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.