currentPosition | rsc::threading::OrderedQueueDispatcherPool< M, R > | private |
deliverFunction typedef | rsc::threading::OrderedQueueDispatcherPool< M, R > | |
deliveryHandler | rsc::threading::OrderedQueueDispatcherPool< M, R > | private |
DeliveryHandlerPtr typedef | rsc::threading::OrderedQueueDispatcherPool< M, R > | |
filterFunction typedef | rsc::threading::OrderedQueueDispatcherPool< M, R > | |
filterHandler | rsc::threading::OrderedQueueDispatcherPool< M, R > | private |
FilterHandlerPtr typedef | rsc::threading::OrderedQueueDispatcherPool< M, R > | |
finishedWork(boost::shared_ptr< Receiver > receiver) | rsc::threading::OrderedQueueDispatcherPool< M, R > | inlineprivate |
interrupted | rsc::threading::OrderedQueueDispatcherPool< M, R > | private |
jobsAvailable | rsc::threading::OrderedQueueDispatcherPool< M, R > | private |
jobsAvailableCondition | rsc::threading::OrderedQueueDispatcherPool< M, R > | private |
nextJob(const unsigned int &, boost::shared_ptr< Receiver > &receiver) | rsc::threading::OrderedQueueDispatcherPool< M, R > | inlineprivate |
OrderedQueueDispatcherPool(const unsigned int &threadPoolSize, deliverFunction delFunc) | rsc::threading::OrderedQueueDispatcherPool< M, R > | inline |
OrderedQueueDispatcherPool(const unsigned int &threadPoolSize, deliverFunction delFunc, filterFunction filterFunc) | rsc::threading::OrderedQueueDispatcherPool< M, R > | inline |
OrderedQueueDispatcherPool(const unsigned int &threadPoolSize, DeliveryHandlerPtr deliveryHandler) | rsc::threading::OrderedQueueDispatcherPool< M, R > | inline |
OrderedQueueDispatcherPool(const unsigned int &threadPoolSize, DeliveryHandlerPtr deliveryHandler, FilterHandlerPtr filterHandler) | rsc::threading::OrderedQueueDispatcherPool< M, R > | inline |
parallelCalls | rsc::threading::OrderedQueueDispatcherPool< M, R > | private |
push(const M &message) | rsc::threading::OrderedQueueDispatcherPool< M, R > | inline |
receivers | rsc::threading::OrderedQueueDispatcherPool< M, R > | private |
receiversMutex | rsc::threading::OrderedQueueDispatcherPool< M, R > | private |
registerReceiver(boost::shared_ptr< R > receiver) | rsc::threading::OrderedQueueDispatcherPool< M, R > | inline |
setParallelCalls(const bool &allow) | rsc::threading::OrderedQueueDispatcherPool< M, R > | inline |
start() | rsc::threading::OrderedQueueDispatcherPool< M, R > | inline |
started | rsc::threading::OrderedQueueDispatcherPool< M, R > | private |
stop() | rsc::threading::OrderedQueueDispatcherPool< M, R > | inline |
threadPool | rsc::threading::OrderedQueueDispatcherPool< M, R > | private |
threadPoolSize | rsc::threading::OrderedQueueDispatcherPool< M, R > | private |
unregisterReceiver(boost::shared_ptr< R > receiver) | rsc::threading::OrderedQueueDispatcherPool< M, R > | inline |
worker(const unsigned int &workerNum) | rsc::threading::OrderedQueueDispatcherPool< M, R > | inlineprivate |
~OrderedQueueDispatcherPool() | rsc::threading::OrderedQueueDispatcherPool< M, R > | inlinevirtual |