org.activemq.ra
Class ActiveMQBaseEndpointWorker
java.lang.Object
org.activemq.ra.ActiveMQBaseEndpointWorker
- Direct Known Subclasses:
- ActiveMQAsfEndpointWorker, ActiveMQPollingEndpointWorker
public abstract class ActiveMQBaseEndpointWorker
- extends 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 |
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
ActiveMQBaseEndpointWorker
public ActiveMQBaseEndpointWorker(ActiveMQResourceAdapter adapter,
ActiveMQEndpointActivationKey key)
throws ResourceException
- Throws:
ResourceException
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-2010 Protique, Ltd.. All Rights Reserved.