#include <OnDemandConsumerImpl.h>
Public Member Functions | |
OnDemandConsumerImpl (AbstractMsgQueue *msgQueue) | |
virtual | ~OnDemandConsumerImpl () |
OnDemandMessage * | getMessage () |
receive the next message which is on the queue (blocking) | |
Private Attributes | |
AbstractMsgQueue * | msgQueue_ |
the message queue used to interchange messages |
Definition at line 12 of file OnDemandConsumerImpl.h.
fesa::OnDemandConsumerImpl::OnDemandConsumerImpl | ( | AbstractMsgQueue * | msgQueue | ) |
Definition at line 18 of file OnDemandConsumerImpl.cpp.
References msgQueue_, and fesa::AbstractMsgQueue::purge().
fesa::OnDemandConsumerImpl::~OnDemandConsumerImpl | ( | ) | [virtual] |
Definition at line 23 of file OnDemandConsumerImpl.cpp.
OnDemandMessage * fesa::OnDemandConsumerImpl::getMessage | ( | ) | [virtual] |
receive the next message which is on the queue (blocking)
Implements fesa::OnDemandConsumer.
Definition at line 28 of file OnDemandConsumerImpl.cpp.
References fesa::AbstractMsgQueue::consumeMsg(), fesa::AbstractMsgQueue::getQueueName(), and msgQueue_.
the message queue used to interchange messages
Definition at line 30 of file OnDemandConsumerImpl.h.
Referenced by getMessage(), and OnDemandConsumerImpl().