org.codehaus.activemq.ra
Class ActiveMQPollingEndpointWorker.InboundEndpointWork

java.lang.Object
  org.codehaus.activemq.ra.ActiveMQPollingEndpointWorker.InboundEndpointWork

All Implemented Interfaces:

java.lang.Runnable, Work

Enclosing class:

ActiveMQPollingEndpointWorker

public static class ActiveMQPollingEndpointWorker.InboundEndpointWork

extends java.lang.Object

implements Work

Field Summary

(package private) ActiveMQMessage

message

Constructor Summary

ActiveMQPollingEndpointWorker.InboundEndpointWork(ActiveMQSession session, MessageEndpoint endpoint, CircularQueue workers)

Method Summary

void	release()
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

message

ActiveMQMessage message

Constructor Detail

ActiveMQPollingEndpointWorker.InboundEndpointWork

public ActiveMQPollingEndpointWorker.InboundEndpointWork(ActiveMQSession session,
                                                         MessageEndpoint endpoint,
                                                         CircularQueue workers)
                                                  throws JMSException

Parameters:

session -

endpoint -

workers -

Throws:

JMSException

Method Detail

release

public void release()

Specified by:

release in interface Work

run

public void run()

Specified by:

run in interface java.lang.Runnable

See Also:

Runnable.run()