ProcessedEventBackup.h

/**************************************************************************
 * basf2 (Belle II Analysis Software Framework)                           *
 * Author: The Belle II Collaboration                                     *
 *                                                                        *
 * See git log for contributors and copyright holders.                    *
 * This file is licensed under LGPL-3.0, see LICENSE.md.                  *
 **************************************************************************/
#pragma once
 
#include <framework/dataobjects/EventMetaData.h>
#include <framework/pcore/EvtMessage.h>
#include <framework/pcore/zmq/messages/ZMQMessageFactory.h>
#include <memory>
#include <chrono>
 
namespace Belle2 {
  class ProcessedEventBackup {
    using TimeStamp = std::chrono::time_point<std::chrono::system_clock>;
  public:
    ProcessedEventBackup(std::unique_ptr<EvtMessage> evtMsg, const EventMetaData& evtMetaData,
                         unsigned int workerId);
 
    bool operator==(const EventMetaData& rhs);
 
    template <class AZMQClient>
    void sendToSocket(const AZMQClient& socket);
 
    const EventMetaData& getEventMetaData() const;
    const TimeStamp& getTimestamp() const;
    const unsigned int& getWorkerId() const;
 
  private:
    std::unique_ptr<EvtMessage> m_eventMessage;
    EventMetaData m_eventMetaData;
    unsigned int m_workerId;
    TimeStamp m_timestamp = std::chrono::system_clock::now();
  };
 
  template <class AZMQClient>
  void ProcessedEventBackup::sendToSocket(const AZMQClient& socket)
  {
    auto message = ZMQMessageFactory::createMessage(EMessageTypes::c_eventMessage, m_eventMessage);
    socket.publish(std::move(message));
    B2DEBUG(100, "sent backup evt: " << m_eventMetaData.getEvent());
  }
}