FairMQ/examples/MQ/2-sampler-processor-sink/FairMQExample2Processor.cxx

/********************************************************************************
 *    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"                       *
 ********************************************************************************/

#include "FairMQExample2Processor.h"
#include "FairMQLogger.h"

#include <string>

using namespace std;

FairMQExample2Processor::FairMQExample2Processor()
{
    OnData("data1", &FairMQExample2Processor::HandleData);
}

bool FairMQExample2Processor::HandleData(FairMQMessagePtr& msg, int /*index*/)
{
    LOG(info) << "Received data, processing...";

    // Modify the received string
    string* text = new std::string(static_cast<char*>(msg->GetData()), msg->GetSize());
    *text += " (modified by " + fId + ")";

    // create message object with a pointer to the data buffer,
    // its size,
    // custom deletion function (called when transfer is done),
    // and pointer to the object managing the data buffer
    FairMQMessagePtr msg2(NewMessage(const_cast<char*>(text->c_str()),
                                     text->length(),
                                     [](void* /*data*/, void* object) { delete static_cast<string*>(object); },
                                     text));

    // Send out the output message
    if (Send(msg2, "data2") < 0)
    {
        return false;
    }

    return true;
}

FairMQExample2Processor::~FairMQExample2Processor()
{
}