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