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;
MapType popMessage()
Pop an object from the front of the message queue.
size_t queueSize()
Retrieve the current size of the message queue.
const MapType & frontMessage()
Peek at the object at the front of the queue.
void messageArrived(MapType obj) override
This adds a message to the queue.