org.codehaus.activemq.ra
Class ActiveMQBaseEndpointWorker
java.lang.Object
org.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 $
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
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.