org.apache.activemq.ra
Class ActiveMQEndpointWorker
java.lang.Object
org.apache.activemq.ra.ActiveMQEndpointWorker
public class ActiveMQEndpointWorker
- extends java.lang.Object
$Date$
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ON_MESSAGE_METHOD
public static final java.lang.reflect.Method ON_MESSAGE_METHOD
endpointActivationKey
protected final ActiveMQEndpointActivationKey endpointActivationKey
endpointFactory
protected final javax.resource.spi.endpoint.MessageEndpointFactory endpointFactory
workManager
protected final javax.resource.spi.work.WorkManager workManager
transacted
protected final boolean transacted
ActiveMQEndpointWorker
protected ActiveMQEndpointWorker(MessageResourceAdapter adapter,
ActiveMQEndpointActivationKey key)
throws javax.resource.ResourceException
- Throws:
javax.resource.ResourceException
safeClose
public static void safeClose(javax.jms.Connection c)
- Parameters:
c
-
safeClose
public static void safeClose(javax.jms.ConnectionConsumer cc)
- Parameters:
cc
-
start
public void start()
throws javax.resource.ResourceException
- Throws:
javax.resource.ResourceException
stop
public void stop()
throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
registerThreadSession
protected void registerThreadSession(javax.jms.Session session)
unregisterThreadSession
protected void unregisterThreadSession(javax.jms.Session session)
getConnection
protected ActiveMQConnection getConnection()
Copyright © 2005-2016. All Rights Reserved.