LocalMsgQueue.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef LOCAL_MSG_QUEUE_H_
#define LOCAL_MSG_QUEUE_H_

#include <fesa-core/Core/AbstractMsgQueue.h>
#include <fesa-core/Utilities/Mutex.h>
#include <fesa-core/Utilities/ConditionalVariable.h>

#include <string>
#include <queue>

namespace fesa
{

class LocalMsgQueue : public AbstractMsgQueue
{
  public:

    LocalMsgQueue(const std::string& name, uint32_t queueLength);

    ~LocalMsgQueue();

    void postMsg(AbstractMessage* msg);

    AbstractMessage* consumeMsg();

    void purge();

    uint32_t getCurrentMsgCount();


  private:

    std::priority_queue<AbstractMessage*> msgQueue_;

    Mutex accessMutex_;

    ConditionalVariable newMsgCondVar_;

    LocalMsgQueue(const LocalMsgQueue&);

    LocalMsgQueue& operator=(const LocalMsgQueue&);
};

} // fesa

#endif // LOCAL_MSG_QUEUE_H_