org.codehaus.activemq.ra
Class ActiveMQPollingEndpointWorker.InboundEndpointWork
java.lang.Object
org.codehaus.activemq.ra.ActiveMQPollingEndpointWorker.InboundEndpointWork
- All Implemented Interfaces:
- Runnable, Work
- Enclosing class:
- ActiveMQPollingEndpointWorker
- public static class ActiveMQPollingEndpointWorker.InboundEndpointWork
- extends Object
- implements Work
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
message
ActiveMQMessage message
ActiveMQPollingEndpointWorker.InboundEndpointWork
public ActiveMQPollingEndpointWorker.InboundEndpointWork(ActiveMQSession session,
MessageEndpoint endpoint,
CircularQueue workers)
throws JMSException
- Parameters:
session
- endpoint
- workers
-
- Throws:
JMSException
release
public void release()
- Specified by:
release
in interface Work
run
public void run()
- Specified by:
run
in interface Runnable
- See Also:
Runnable.run()
Copyright © 2004 Protique, Ltd.. All Rights Reserved.