 |
Belle II Software
release-05-02-19
|
12 #include <framework/dataobjects/EventMetaData.h>
13 #include <framework/pcore/EvtMessage.h>
14 #include <framework/pcore/zmq/messages/ZMQMessageFactory.h>
23 class ProcessedEventBackup {
26 using TimeStamp = std::chrono::time_point<std::chrono::system_clock>;
30 unsigned int workerId);
36 template <
class AZMQClient>
57 template <
class AZMQClient>
61 socket.publish(std::move(message));
void sendToSocket(const AZMQClient &socket)
Publish this event backup directly to the given client.
unsigned int m_workerId
Getter for the stored worker id.
std::unique_ptr< EvtMessage > m_eventMessage
Stored event message.
std::chrono::time_point< std::chrono::system_clock > TimeStamp
Short for the class of the time stamp (it is a system clock time stamp)
const EventMetaData & getEventMetaData() const
Getter for the stored event meta data.
EventMetaData m_eventMetaData
Getter for the stored event meta data.
const TimeStamp & getTimestamp() const
Getter for the stored time stamp.
TimeStamp m_timestamp
Getter for the stored time stamp.
ProcessedEventBackup(std::unique_ptr< EvtMessage > evtMsg, const EventMetaData &evtMetaData, unsigned int workerId)
Constructor setting the informations. Takes ownership of the evtMsg.
Abstract base class for different kinds of events.
bool operator==(const EventMetaData &rhs)
Compare operator needed in the backup list.
static auto createMessage(const std::string &msgIdentity, const EMessageTypes msgType, const std::unique_ptr< EvtMessage > &eventMessage)
Create an ID Message out of an identity, the type and an event message.
const unsigned int & getWorkerId() const
Getter for the stored worker id.