activemq-cpp-3.9.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. More... | |
virtual | ~ActiveMQSessionExecutor () |
Calls stop() then clear(). More... | |
virtual void | execute (const Pointer< MessageDispatch > &data) |
Executes the dispatch. More... | |
virtual void | executeFirst (const Pointer< MessageDispatch > &data) |
Executes the dispatch. More... | |
virtual void | clearMessagesInProgress () |
Removes all messages in the Dispatch Channel so that non are delivered. More... | |
virtual bool | hasUncomsumedMessages () const |
virtual void | wakeup () |
wakeup this executer and dispatch any pending messages. More... | |
virtual void | start () |
Starts the dispatching. More... | |
virtual void | stop () |
Stops dispatching. More... | |
virtual void | close () |
Terminates the dispatching thread. More... | |
virtual bool | isRunning () const |
virtual bool | isEmpty () |
virtual void | clear () |
Removes all queued messages and destroys them. More... | |
virtual bool | iterate () |
Iterates on the MessageDispatchChannel sending all pending messages to the Consumers they are destined for. More... | |
std::vector< Pointer < MessageDispatch > > | getUnconsumedMessages () |
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.
Implements activemq::threads::Task.
|
virtual |
Starts the dispatching.
|
virtual |
Stops dispatching.
|
virtual |
wakeup this executer and dispatch any pending messages.