12 #include <framework/dataobjects/EventMetaData.h>
13 #include <framework/pcore/zmq/messages/ZMQDefinitions.h>
14 #include <framework/pcore/zmq/utils/EventMetaDataSerialization.h>
15 #include <framework/pcore/EvtMessage.h>
16 #include <framework/datastore/StoreObjPtr.h>
27 class ZMQMessageHelper {
45 return zmq::message_t(s.c_str(), s.length());
58 return zmq::message_t(message.c_str(), message.length());
62 static zmq::message_t
createZMQMessage(
const std::unique_ptr<EvtMessage>& evtMessage)
65 return zmq::message_t(evtMessage->buffer(), evtMessage->size());