|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.ra.ActiveMQBaseEndpointWorker
org.codehaus.activemq.ra.ActiveMQPollingEndpointWorker
Nested Class Summary | |
static class |
ActiveMQPollingEndpointWorker.InboundEndpointWork
|
Field Summary | |
(package private) static WorkListener |
debugingWorkListener
|
Fields inherited from class org.codehaus.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.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 |
static WorkListener debugingWorkListener
Constructor Detail |
public ActiveMQPollingEndpointWorker(ActiveMQResourceAdapter adapter, ActiveMQEndpointActivationKey key) throws ResourceException
adapter
- key
-
ResourceException
Method Detail |
public void start() throws WorkException, ResourceException
start
in class ActiveMQBaseEndpointWorker
WorkException
ResourceException
public void stop() throws java.lang.InterruptedException
stop
in class ActiveMQBaseEndpointWorker
java.lang.InterruptedException
public void release()
release
in interface Work
Work.release()
public void run()
run
in interface java.lang.Runnable
Runnable.run()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |