MsgQueueFactory.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef MSG_QUEUE_FACTORY_H_
#define MSG_QUEUE_FACTORY_H_

#include <map>
#include <string>

#include <stdint.h>

namespace fesa
{

class AbstractMsgQueue;

class MsgQueueFactory
{
  public:

    ~MsgQueueFactory();

    static AbstractMsgQueue* getOrCreateMsgQueue(const std::string& name, uint32_t queuelength, bool blocking);

  private:

    static std::map<std::string, AbstractMsgQueue*> blockingIPCQueueCol_;

    static std::map<std::string, AbstractMsgQueue*> nonBlockingIPCQueueCol_;

    static std::map<std::string, AbstractMsgQueue*> localQueueCol_;

};

} // fesa

#endif // MSG_QUEUE_FACTORY_H_