ParameterMQServer.h

Go to the documentation of this file.

/********************************************************************************
 *    Copyright (C) 2014 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH    *
 *                                                                              *
 *              This software is distributed under the terms of the             *
 *              GNU Lesser General Public Licence (LGPL) version 3,             *
 *                  copied verbatim in the file "LICENSE"                       *
 ********************************************************************************/
#ifndef PARAMETERMQSERVER_H_
#define PARAMETERMQSERVER_H_

#include <FairMQDevice.h>
#include <string>

class FairRuntimeDb;

class ParameterMQServer : public FairMQDevice
{
  public:
    ParameterMQServer();

    ParameterMQServer(const ParameterMQServer&) = delete;
    ParameterMQServer operator=(const ParameterMQServer&) = delete;

    virtual ~ParameterMQServer();

    virtual void InitTask();
    virtual void Init();
    bool ProcessRequest(FairMQMessagePtr&, int);
    bool ProcessUpdate(FairMQMessagePtr&, int);

    void SetFirstInputName(const std::string& firstInputName) { fFirstInputName = firstInputName; }
    std::string GetFirstInputName() { return fFirstInputName; }
    void SetFirstInputType(const std::string& firstInputType) { fFirstInputType = firstInputType; }
    std::string GetFirstInputType() { return fFirstInputType; }
    void SetSecondInputName(const std::string& secondInputName) { fSecondInputName = secondInputName; }
    std::string GetSecondInputName() { return fSecondInputName; }
    void SetSecondInputType(const std::string& secondInputType) { fSecondInputType = secondInputType; }
    std::string GetSecondInputType() { return fSecondInputType; }
    void SetOutputName(const std::string& outputName) { fOutputName = outputName; }
    std::string GetOutputName() { return fOutputName; }
    void SetOutputType(const std::string& outputType) { fOutputType = outputType; }
    std::string GetOutputType() { return fOutputType; }

    void SetChannelName(const std::string& channelName) { fRequestChannelName = channelName; }
    std::string GetChannelName() { return fRequestChannelName; }

    void SetUpdateChannelName(const std::string& channelName) { fUpdateChannelName = channelName; }
    std::string GetUpdateChannelName() { return fUpdateChannelName; }

  private:
    FairRuntimeDb* fRtdb;
    int fRunId;
    int fNofSimDevices;

    std::string fFirstInputName;
    std::string fFirstInputType;
    std::string fSecondInputName;
    std::string fSecondInputType;
    std::string fOutputName;
    std::string fOutputType;

    std::string fRequestChannelName;
    std::string fUpdateChannelName;
};

#endif /* PARAMETERMQSERVER_H_ */