QueuedDecoder.h

// This file may be redistributed and modified only under the terms of
// the GNU Lesser General Public License (See COPYING for details).
// Copyright (C) 2000 Stefanus Du Toit

// $Id$

#ifndef ATLAS_MESSAGE_QUEUEDDECODER_H
#define ATLAS_MESSAGE_QUEUEDDECODER_H

#include <Atlas/Message/DecoderBase.h>
#include <Atlas/Message/Element.h>

#include <queue>

namespace Atlas { namespace Message {

class Element;

typedef std::map<std::string, Element> MapType;

class QueuedDecoder : public DecoderBase
{
public:

    QueuedDecoder() = default;

    size_t queueSize() {
        return m_objectQueue.size();
    }
    MapType popMessage() {
        MapType r = std::move(m_objectQueue.front());
        m_objectQueue.pop();
        return r;
    }
    const MapType& frontMessage() {
        return m_objectQueue.front();
    }

protected:

    void messageArrived(MapType obj) override;
    
private:
    
    std::queue<MapType> m_objectQueue;
};

} } // namespace Atlas::Message

#endif