org.activemq.ra
Class ActiveMQAsfEndpointWorker

java.lang.Object
  extended by org.activemq.ra.ActiveMQBaseEndpointWorker
      extended by org.activemq.ra.ActiveMQAsfEndpointWorker

public class ActiveMQAsfEndpointWorker
extends ActiveMQBaseEndpointWorker

Version:
$Revision: 1.1.1.1 $ $Date: 2005/03/11 21:15:09 $

Field Summary
protected  org.activemq.ActiveMQConnection connection
           
 
Fields inherited from class org.activemq.ra.ActiveMQBaseEndpointWorker
adapter, endpointActivationKey, endpointFactory, ON_MESSAGE_METHOD, transacted, workManager
 
Constructor Summary
ActiveMQAsfEndpointWorker(ActiveMQResourceAdapter adapter, ActiveMQEndpointActivationKey key)
           
 
Method Summary
protected  void registerThreadSession(Session session)
           
 void start()
           
 void stop()
           
protected  void unregisterThreadSession(Session session)
           
 
Methods inherited from class org.activemq.ra.ActiveMQBaseEndpointWorker
safeClose, safeClose, safeClose
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

connection

protected org.activemq.ActiveMQConnection connection
Constructor Detail

ActiveMQAsfEndpointWorker

public ActiveMQAsfEndpointWorker(ActiveMQResourceAdapter adapter,
                                 ActiveMQEndpointActivationKey key)
                          throws ResourceException
Parameters:
adapter -
key -
Throws:
ResourceException
Method Detail

start

public void start()
           throws WorkException,
                  ResourceException
Specified by:
start in class ActiveMQBaseEndpointWorker
Throws:
WorkException
ResourceException

stop

public void stop()
          throws InterruptedException
Specified by:
stop in class ActiveMQBaseEndpointWorker
Throws:
InterruptedException

registerThreadSession

protected void registerThreadSession(Session session)

unregisterThreadSession

protected void unregisterThreadSession(Session session)


Copyright © 2004-2010 Protique, Ltd.. All Rights Reserved.