org.codehaus.activemq
Class ActiveMQSessionExecutor
java.lang.Object
org.codehaus.activemq.ActiveMQSessionExecutor
- All Implemented Interfaces:
- Runnable
- class ActiveMQSessionExecutor
- extends Object
- implements Runnable
A utility class used by the Sessionfor dispatching messages asycnronously to consumers
- Version:
- $Revision: 1.3 $
- See Also:
Session
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ActiveMQSessionExecutor
ActiveMQSessionExecutor(ActiveMQSession session,
MemoryBoundedQueue queue)
setDoDispatch
void setDoDispatch(boolean value)
execute
void execute(ActiveMQMessage message)
executeFirst
void executeFirst(ActiveMQMessage message)
run
public void run()
- implementation of Runnable
- Specified by:
run
in interface Runnable
start
void start()
stop
void stop()
close
void close()
clear
void clear()
dequeueNoWait
ActiveMQMessage dequeueNoWait()
clearMessagesInProgress
protected void clearMessagesInProgress()
Copyright © 2004 Protique, Ltd.. All Rights Reserved.