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 = std::move(m_objectQueue.front());
52 return m_objectQueue.front();
62 std::queue<MapType> m_objectQueue;
void messageArrived(MapType obj) override
This adds a message to the queue.
MapType popMessage()
Pop an object from the front of the message queue.
Definition: QueuedDecoder.h:45
The Atlas namespace.
Definition: Bridge.h:20
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
const MapType & frontMessage()
Peek at the object at the front of the queue.
Definition: QueuedDecoder.h:51
Base class for decoders that take Atlas::Message::Object.
Definition: DecoderBase.h:40