7 #ifndef ATLAS_MESSAGE_QUEUEDDECODER_H 8 #define ATLAS_MESSAGE_QUEUEDDECODER_H 10 #include <Atlas/Message/DecoderBase.h> 11 #include <Atlas/Message/Element.h> 15 namespace Atlas {
namespace Message {
19 typedef std::map<std::string, Element> MapType;
42 return m_objectQueue.size();
46 MapType r = m_objectQueue.front();
52 return m_objectQueue.front();
64 std::queue<MapType> m_objectQueue;
const MapType frontMessage()
Peek at the object at the front of the queue.
Definition: QueuedDecoder.h:51
const MapType popMessage()
Pop an object from the front of the message queue.
Definition: QueuedDecoder.h:45
The Atlas namespace.
Definition: Bridge.h:20
void clearQueue()
Clear the message queue.
void messageArrived(const MapType &obj)
This adds a message to the queue.
Decoder that presents a queue of Atlas::Message::Element.
Definition: QueuedDecoder.h:34
size_t queueSize()
Retrieve the current size of the message queue.
Definition: QueuedDecoder.h:41
Base class for decoders that take Atlas::Message::Object.
Definition: DecoderBase.h:40