PndMQExample1Sampler Class Reference

#include <PndMQExample1Sampler.h>

Inheritance diagram for PndMQExample1Sampler:

Public Types
enum	{ Text = FairMQDevice::Last, Last }

Public Member Functions
	PndMQExample1Sampler ()
virtual	~PndMQExample1Sampler ()
virtual void	SetProperty (const int key, const std::string &value)
virtual std::string	GetProperty (const int key, const std::string &default_="")
virtual void	SetProperty (const int key, const int value)
virtual int	GetProperty (const int key, const int default_=0)

Static Public Member Functions
static void	CustomCleanup (void *data, void *hint)

Protected Member Functions
virtual void	Run ()

Protected Attributes
std::string	fText

Detailed Description

PndMQExample1Sampler.h

Since

2014-10-10

Author

A. Rybalchenko

Definition at line 22 of file PndMQExample1Sampler.h.

Member Enumeration Documentation

anonymous enum

Enumerator
Text
Last

Definition at line 25 of file PndMQExample1Sampler.h.

    {
        Text = FairMQDevice::Last,
        Last
    };

Constructor & Destructor Documentation

PndMQExample1Sampler::PndMQExample1Sampler

(

)

Definition at line 25 of file PndMQExample1Sampler.cxx.

    : fText()
{
}

PndMQExample1Sampler::~PndMQExample1Sampler ( )

virtual

Definition at line 51 of file PndMQExample1Sampler.cxx.

{
}

Member Function Documentation

void PndMQExample1Sampler::CustomCleanup ( void *  data, void *  hint  )

static

Definition at line 30 of file PndMQExample1Sampler.cxx.

Referenced by Run().

{
    delete (string*)object;
}

virtual std::string PndMQExample1Sampler::GetProperty ( const int  key, const std::string &  default_ = ""  )

virtual

int PndMQExample1Sampler::GetProperty ( const int  key, const int  default_ = 0  )

virtual

Definition at line 90 of file PndMQExample1Sampler.cxx.

{
    switch (key)
    {
        default:
            return FairMQDevice::GetProperty(key, default_);
    }
}

void PndMQExample1Sampler::Run ( )

protectedvirtual

Definition at line 35 of file PndMQExample1Sampler.cxx.

References CustomCleanup(), and fText.

{
    while (CheckCurrentState(RUNNING))
    {
        boost::this_thread::sleep(boost::posix_time::milliseconds(1000));

        string* text = new string(fText);

        unique_ptr<FairMQMessage> msg(fTransportFactory->CreateMessage(const_cast<char*>(text->c_str()), text->length(), CustomCleanup, text));

        LOG(INFO) << "Sending \"" << fText << "\"";

        fChannels.at("data-out").at(0).Send(msg);
    }
}

virtual void PndMQExample1Sampler::SetProperty ( const int  key, const std::string &  value  )

virtual

Referenced by main().

void PndMQExample1Sampler::SetProperty ( const int  key, const int  value  )

virtual

Definition at line 80 of file PndMQExample1Sampler.cxx.

{
    switch (key)
    {
        default:
            FairMQDevice::SetProperty(key, value);
            break;
    }
}

Member Data Documentation

std::string PndMQExample1Sampler::fText

protected

Definition at line 41 of file PndMQExample1Sampler.h.

Referenced by Run().

---

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

• PndMQExample1Sampler.h
• PndMQExample1Sampler.cxx