org.activemq.ra
Class ActiveMQPollingEndpointWorker

java.lang.Object
  extended by org.activemq.ra.ActiveMQBaseEndpointWorker
      extended by org.activemq.ra.ActiveMQPollingEndpointWorker
All Implemented Interfaces:
Runnable, Work

public class ActiveMQPollingEndpointWorker
extends ActiveMQBaseEndpointWorker
implements Work

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

Field Summary
 
Fields inherited from class org.activemq.ra.ActiveMQBaseEndpointWorker
adapter, endpointActivationKey, endpointFactory, ON_MESSAGE_METHOD, transacted, workManager
 
Constructor Summary
ActiveMQPollingEndpointWorker(ActiveMQResourceAdapter adapter, ActiveMQEndpointActivationKey key)
           
 
Method Summary
 void release()
           
 void run()
          The WorkManager has started up and we now need to pull message off the destination and push them to an endpoint.
 void start()
           
 void stop()
           
 
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
 

Constructor Detail

ActiveMQPollingEndpointWorker

public ActiveMQPollingEndpointWorker(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

release

public void release()
Specified by:
release in interface Work
See Also:
Work.release()

run

public void run()
The WorkManager has started up and we now need to pull message off the destination and push them to an endpoint.

Specified by:
run in interface Runnable
See Also:
Runnable.run()


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