diff --git a/examples/MQ/8-multipart/FairMQExample8Sampler.cxx b/examples/MQ/8-multipart/FairMQExample8Sampler.cxx index 45106c20..8067601f 100644 --- a/examples/MQ/8-multipart/FairMQExample8Sampler.cxx +++ b/examples/MQ/8-multipart/FairMQExample8Sampler.cxx @@ -41,13 +41,6 @@ void FairMQExample8Sampler::Run() LOG(INFO) << "Sending header with stopFlag: " << header->stopFlag; FairMQParts parts; - - parts.AddPart(NewMessage(header, // data pointer - sizeof(Ex8Header), // data size - [](void* data, void* hint) { delete static_cast(data); } // callback to deallocate after the transfer - )); - parts.AddPart(NewMessage(1000)); - LOG(INFO) << "Sending body of size: " << parts.At(1)->GetSize(); Send(parts, "data-out"); diff --git a/examples/MQ/8-multipart/FairMQExample8Sampler.h b/examples/MQ/8-multipart/FairMQExample8Sampler.h index 3712cd8f..479a057e 100644 --- a/examples/MQ/8-multipart/FairMQExample8Sampler.h +++ b/examples/MQ/8-multipart/FairMQExample8Sampler.h @@ -19,48 +19,6 @@ #include "FairMQDevice.h" - -struct MyPoint -{ - /* data */ - double x=6; - double y=6; - double z=6; -}; - -struct Ex8Header { - int32_t stopFlag; -}; - - - -struct MyPointSerializer -{ - void Serialize(std::unique_ptr& msg, MyPoint* input) - { - int DataSize = sizeof(MyPoint); - msg->Rebuild(DataSize); - MyPoint* digiptr = reinterpret_cast(msg->GetData()); - digiptr->x=input->x; - digiptr->y=input->y; - digiptr->z=input->z; - } - - void Deserialize(std::unique_ptr& msg, MyPoint* input) - { - MyPoint* digiptr = static_cast(msg->GetData()); - input->x=digiptr->x; - input->y=digiptr->y; - input->z=digiptr->z; - } - -}; - - - - - - class FairMQExample8Sampler : public FairMQDevice { public: diff --git a/examples/MQ/8-multipart/FairMQExample8Sink.h b/examples/MQ/8-multipart/FairMQExample8Sink.h index c3a45675..e71851b2 100644 --- a/examples/MQ/8-multipart/FairMQExample8Sink.h +++ b/examples/MQ/8-multipart/FairMQExample8Sink.h @@ -17,51 +17,6 @@ #include "FairMQDevice.h" - -struct Ex8Header { - int32_t stopFlag; -}; - - -struct MyPoint -{ - /* data */ - double x=1; - double y=1; - double z=1; -}; - - -struct MyPointSerializer -{ - void Serialize(std::unique_ptr& msg, MyPoint* input) - { - int DataSize = sizeof(MyPoint); - msg->Rebuild(DataSize); - MyPoint* digiptr = reinterpret_cast(msg->GetData()); - digiptr->x=input->x; - digiptr->y=input->y; - digiptr->z=input->z; - } - - void Deserialize(std::unique_ptr& msg, MyPoint* input) - { - MyPoint* digiptr = static_cast(msg->GetData()); - input->x=digiptr->x; - input->y=digiptr->y; - input->z=digiptr->z; - } - - void Deserialize(FairMQMessage& msg, MyPoint* input) - { - MyPoint* digiptr = static_cast(msg.GetData()); - input->x=digiptr->x; - input->y=digiptr->y; - input->z=digiptr->z; - } - -}; - class FairMQExample8Sink : public FairMQDevice { public: