org.codehaus.activemq.ra
Class ActiveMQAsfEndpointWorker

java.lang.Object
  extended byorg.codehaus.activemq.ra.ActiveMQBaseEndpointWorker
      extended byorg.codehaus.activemq.ra.ActiveMQAsfEndpointWorker

public class ActiveMQAsfEndpointWorker
extends ActiveMQBaseEndpointWorker

Version:
$Revision: 1.3 $ $Date: 2004/07/31 21:11:00 $

Nested Class Summary
(package private)  class ActiveMQAsfEndpointWorker.ServerSessionImpl
           
(package private)  class ActiveMQAsfEndpointWorker.ServerSessionPoolImpl
           
 
Field Summary
(package private)  ConnectionConsumer consumer
           
 
Fields inherited from class org.codehaus.activemq.ra.ActiveMQBaseEndpointWorker
adapter, endpointActivationKey, endpointFactory, ON_MESSAGE_METHOD, transacted, workManager
 
Constructor Summary
ActiveMQAsfEndpointWorker(ActiveMQResourceAdapter adapter, ActiveMQEndpointActivationKey key)
           
 
Method Summary
 void start()
           
 void stop()
           
 
Methods inherited from class org.codehaus.activemq.ra.ActiveMQBaseEndpointWorker
safeClose, safeClose
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

consumer

ConnectionConsumer consumer
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


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