_consChangeWait | ark::AsyncConsumer< T, SourceQueuePolicy > | [private] |
_consNewNanos | ark::AsyncConsumer< T, SourceQueuePolicy > | [private] |
_consNewSecs | ark::AsyncConsumer< T, SourceQueuePolicy > | [private] |
_consumerThread | ark::AsyncConsumer< T, SourceQueuePolicy > | [private] |
_consWaitNanos | ark::AsyncConsumer< T, SourceQueuePolicy > | [private] |
_consWaitSecs | ark::AsyncConsumer< T, SourceQueuePolicy > | [private] |
_exitConsumptionFlag | ark::AsyncConsumer< T, SourceQueuePolicy > | [private] |
_exitConsumptionMutex | ark::AsyncConsumer< T, SourceQueuePolicy > | [private] |
AsyncConsumer() | ark::AsyncConsumer< T, SourceQueuePolicy > | [inline] |
consume(typename boost::add_reference< T >::type msg, SourceQueue &)=0 | ark::AsyncConsumer< T, SourceQueuePolicy > | [pure virtual] |
consumeLoop() | ark::AsyncConsumer< T, SourceQueuePolicy > | [inline] |
consumeLoopOnce() | ark::AsyncConsumer< T, SourceQueuePolicy > | [inline] |
consumerDone() | ark::AsyncConsumer< T, SourceQueuePolicy > | [inline, virtual] |
consumptionWaitTime() const | ark::AsyncConsumer< T, SourceQueuePolicy > | [inline] |
isConsuming() const | ark::AsyncConsumer< T, SourceQueuePolicy > | [inline] |
scheduleConsumption(typename boost::add_reference< T >::type t) | ark::AsyncConsumer< T, SourceQueuePolicy > | [inline] |
scoped_lock typedef | ark::AsyncConsumer< T, SourceQueuePolicy > | [private] |
setConsumptionWaitTime(unsigned secs, unsigned nanos) | ark::AsyncConsumer< T, SourceQueuePolicy > | [inline] |
SourceQueue typedef | ark::AsyncConsumer< T, SourceQueuePolicy > | |
startConsuming() | ark::AsyncConsumer< T, SourceQueuePolicy > | [inline, virtual] |
stopConsuming(bool wait=false) | ark::AsyncConsumer< T, SourceQueuePolicy > | [inline, virtual] |
ThreadHandle typedef | ark::AsyncConsumer< T, SourceQueuePolicy > | [private] |
whileNotConsuming() | ark::AsyncConsumer< T, SourceQueuePolicy > | [inline, virtual] |
~AsyncConsumer() | ark::AsyncConsumer< T, SourceQueuePolicy > | [inline, virtual] |