org.activemq.ra
Class ActiveMQBaseEndpointWorker

java.lang.Object
org.activemq.ra.ActiveMQBaseEndpointWorker
- Direct Known Subclasses:
- ActiveMQAsfEndpointWorker, ActiveMQPollingEndpointWorker
- public abstract class ActiveMQBaseEndpointWorker
- extends java.lang.Object
- Version:
- $Revision: 1.1.1.1 $ $Date: 2005/03/11 21:15:09 $
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
log
private static final org.apache.commons.logging.Log log
ON_MESSAGE_METHOD
public static final java.lang.reflect.Method ON_MESSAGE_METHOD
adapter
protected ActiveMQResourceAdapter adapter
endpointActivationKey
protected ActiveMQEndpointActivationKey endpointActivationKey
endpointFactory
protected javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory
workManager
protected javax.resource.spi.work.WorkManager workManager
transacted
protected boolean transacted
ActiveMQBaseEndpointWorker
public ActiveMQBaseEndpointWorker(ActiveMQResourceAdapter adapter,
ActiveMQEndpointActivationKey key)
throws javax.resource.ResourceException
safeClose
public static void safeClose(javax.jms.Session s)
safeClose
public static void safeClose(javax.jms.Connection c)
safeClose
public static void safeClose(javax.jms.ConnectionConsumer cc)
start
public abstract void start()
throws javax.resource.spi.work.WorkException,
javax.resource.ResourceException
stop
public abstract void stop()
throws java.lang.InterruptedException