activemq-cpp-3.6.0
|
Delegate dispatcher for a single session. More...
#include <src/main/activemq/core/ActiveMQSessionExecutor.h>
Public Member Functions | |
ActiveMQSessionExecutor (activemq::core::kernels::ActiveMQSessionKernel *session) | |
Creates an un-started executor for the given session. | |
virtual | ~ActiveMQSessionExecutor () |
Calls stop() then clear(). | |
virtual void | execute (const Pointer< MessageDispatch > &data) |
Executes the dispatch. | |
virtual void | executeFirst (const Pointer< MessageDispatch > &data) |
Executes the dispatch. | |
virtual void | clearMessagesInProgress () |
Removes all messages in the Dispatch Channel so that non are delivered. | |
virtual bool | hasUncomsumedMessages () const |
virtual void | wakeup () |
wakeup this executer and dispatch any pending messages. | |
virtual void | start () |
Starts the dispatching. | |
virtual void | stop () |
Stops dispatching. | |
virtual void | close () |
Terminates the dispatching thread. | |
virtual bool | isRunning () const |
virtual bool | isEmpty () |
virtual void | clear () |
Removes all queued messages and destroys them. | |
virtual bool | iterate () |
Iterates on the MessageDispatchChannel sending all pending messages to the Consumers they are destined for. | |
std::vector< Pointer < MessageDispatch > > | getUnconsumedMessages () |
Additional Inherited Members | |
Private Member Functions inherited from activemq::threads::Task | |
virtual | ~Task () |
virtual bool | iterate ()=0 |
Perform one iteration of work, returns true if the task needs to run again to complete or false to indicate that the task is now complete. |
Delegate dispatcher for a single session.
Contains a thread to provide for asynchronous dispatching.
activemq::core::ActiveMQSessionExecutor::ActiveMQSessionExecutor | ( | activemq::core::kernels::ActiveMQSessionKernel * | session | ) |
Creates an un-started executor for the given session.
|
virtual |
|
inlinevirtual |
Removes all queued messages and destroys them.
|
inlinevirtual |
Removes all messages in the Dispatch Channel so that non are delivered.
|
inlinevirtual |
Terminates the dispatching thread.
Once this is called, the executor is no longer usable.
|
virtual |
Executes the dispatch.
Adds the given data to the end of the queue.
data | - the data to be dispatched. |
|
virtual |
Executes the dispatch.
Adds the given data to the beginning of the queue.
data | - the data to be dispatched. |
|
inline |
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
virtual |
Iterates on the MessageDispatchChannel sending all pending messages to the Consumers they are destined for.
|
virtual |
Starts the dispatching.
|
virtual |
Stops dispatching.
|
virtual |
wakeup this executer and dispatch any pending messages.