org.codehaus.activemq.ra
Class ActiveMQAsfEndpointWorker

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

Specified by:

stop in class ActiveMQBaseEndpointWorker

Throws:

java.lang.InterruptedException