NotificationProducer.h

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#ifndef NOTIFICATION_PRODUCER_H_
#define NOTIFICATION_PRODUCER_H_

#include <fesa-core/Core/FesaDefs.h>
#include <fesa-core/Core/AbstractMsgQueue.h>

#include <string>

namespace fesa
{

class ManualNotificationMessage;
class MultiplexingContext;

class NotificationProducer
{
  public:

    void sendAutomaticNotification(const uint32_t& notificationID,
                                   MultiplexingContext& muxContext, uint32_t msgPrio = DEFAULT_MQ_PRIO);

    void sendManualNotification(ManualNotificationMessage& manMsg);

    void sendCommandMessage(const std::string &command, const std::string &parameter1,
                            const std::string &parameter2, uint32_t msgPrio = DEFAULT_MQ_PRIO);

    uint32_t getCurrentMsgCount();

    static NotificationProducer* getInstance();

  private:

    static void releaseInstance();

    AbstractMsgQueue* msgQueuePtr_;

    static NotificationProducer* theInstance_;

    NotificationProducer(const std::string& queueName);

    NotificationProducer(const NotificationProducer& other);

    NotificationProducer& operator=(const NotificationProducer& other);

    ~NotificationProducer();

    //for releaseInstance() at the cleanup
    friend class AbstractEquipment;
};

inline uint32_t NotificationProducer::getCurrentMsgCount()
{
    return msgQueuePtr_->getCurrentMsgCount();
}

} // fesa

#endif // NOTIFICATION_PRODUCER_H_