7#ifndef ATLAS_MESSAGE_QUEUEDDECODER_H
8#define ATLAS_MESSAGE_QUEUEDDECODER_H
10#include <Atlas/Message/DecoderBase.h>
11#include <Atlas/Message/Element.h>
15namespace Atlas {
namespace Message {
19typedef 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.
const MapType & frontMessage()
Peek at the object at the front of the queue.
size_t queueSize()
Retrieve the current size of the message queue.
void messageArrived(MapType obj) override
This adds a message to the queue.