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;
Base class for decoders that take Atlas::Message::Object.
Definition: DecoderBase.h:40
const MapType popMessage()
Pop an object from the front of the message queue.
Definition: QueuedDecoder.h:45
Decoder that presents a queue of Atlas::Message::Element.
Definition: QueuedDecoder.h:34
void messageArrived(const MapType &obj)
This adds a message to the queue.
void clearQueue()
Clear the message queue.
The Atlas namespace.
Definition: Bridge.h:20
const MapType frontMessage()
Peek at the object at the front of the queue.
Definition: QueuedDecoder.h:51
size_t queueSize()
Retrieve the current size of the message queue.
Definition: QueuedDecoder.h:41
Copyright 2000-2004 the respective authors.
This document can be licensed under the terms of the GNU Free Documentation
License or the GNU General Public License and may be freely distributed under
the terms given by one of these licenses.