PndMQExample1Sink Class Reference

#include <PndMQExample1Sink.h>

Inheritance diagram for PndMQExample1Sink:

Public Member Functions
	PndMQExample1Sink ()
virtual	~PndMQExample1Sink ()

Protected Member Functions
virtual void	Run ()

Detailed Description

PndMQExample1Sink.h

Since

2014-10-10

Author

A. Rybalchenko

Definition at line 20 of file PndMQExample1Sink.h.

Constructor & Destructor Documentation

PndMQExample1Sink::PndMQExample1Sink

(

)

Definition at line 23 of file PndMQExample1Sink.cxx.

{
}

PndMQExample1Sink::~PndMQExample1Sink ( )

virtual

Definition at line 42 of file PndMQExample1Sink.cxx.

{
}

Member Function Documentation

void PndMQExample1Sink::Run ( )

protectedvirtual

Definition at line 27 of file PndMQExample1Sink.cxx.

{
    while (CheckCurrentState(RUNNING))
    {
        unique_ptr<FairMQMessage> msg(fTransportFactory->CreateMessage());

        if (fChannels.at("data-in").at(0).Receive(msg) > 0)
        {
            LOG(INFO) << "Received message: \""
                      << string(static_cast<char*>(msg->GetData()), msg->GetSize())
                      << "\"";
        }
    }
}

---

The documentation for this class was generated from the following files:

• PndMQExample1Sink.h
• PndMQExample1Sink.cxx