org.activemq.ra
Class ActiveMQPollingEndpointWorker
java.lang.Object
org.activemq.ra.ActiveMQBaseEndpointWorker
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 $
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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ActiveMQPollingEndpointWorker
public ActiveMQPollingEndpointWorker(ActiveMQResourceAdapter adapter,
ActiveMQEndpointActivationKey key)
throws ResourceException
- Parameters:
adapter
- key
-
- Throws:
ResourceException
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.