org.apache.activemq.ra
Class ActiveMQEndpointWorker
java.lang.Object
org.apache.activemq.ra.ActiveMQEndpointWorker
public class ActiveMQEndpointWorker
- extends Object
- Version:
- $Revision$ $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 Method ON_MESSAGE_METHOD
endpointActivationKey
protected final ActiveMQEndpointActivationKey endpointActivationKey
endpointFactory
protected final MessageEndpointFactory endpointFactory
workManager
protected final WorkManager workManager
transacted
protected final boolean transacted
ActiveMQEndpointWorker
protected ActiveMQEndpointWorker(MessageResourceAdapter adapter,
ActiveMQEndpointActivationKey key)
throws ResourceException
- Throws:
ResourceException
safeClose
public static void safeClose(Connection c)
- Parameters:
c
-
safeClose
public static void safeClose(ConnectionConsumer cc)
- Parameters:
cc
-
start
public void start()
throws ResourceException
- Throws:
ResourceException
stop
public void stop()
throws InterruptedException
- Throws:
InterruptedException
registerThreadSession
protected void registerThreadSession(Session session)
unregisterThreadSession
protected void unregisterThreadSession(Session session)
getConnection
protected ActiveMQConnection getConnection()
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.