FairMQMerger.h
/********************************************************************************
* 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 FAIRMQMERGER_H_
#define FAIRMQMERGER_H_
#include "FairMQDevice.h"
#include <string>
class FairMQMerger : public FairMQDevice
{
public:
FairMQMerger();
virtual ~FairMQMerger();
protected:
bool fMultipart;
std::string fInChannelName;
std::string fOutChannelName;
virtual void RegisterChannelEndpoints() override;
virtual void Run() override;
virtual void InitTask() override;
};
#endif /* FAIRMQMERGER_H_ */
FairMQMerger
Definition: FairMQMerger.h:22
FairMQMerger::Run
virtual void Run() override
Runs the device (to be overloaded in child classes)
Definition: FairMQMerger.cxx:48
FairMQDevice
Definition: FairMQDevice.h:46
FairMQMerger::InitTask
virtual void InitTask() override
Task initialization (can be overloaded in child classes)
Definition: FairMQMerger.cxx:41

privacy