Subscriber.hpp

Go to the documentation of this file.

 
#ifndef IPM_INCLUDE_IPM_SUBSCRIBER_HPP_
#define IPM_INCLUDE_IPM_SUBSCRIBER_HPP_
 
#include "ipm/Receiver.hpp"
 
#include "cetlib/BasicPluginFactory.h"
#include "cetlib/compiler_macros.h"
#include "ers/Issue.hpp"
#include "nlohmann/json.hpp"
 
#include <memory>
#include <string>
#include <vector>
 
namespace dunedaq::ipm {
 
class Subscriber : public Receiver
{
 
public:
  Subscriber() = default;
 
  virtual void subscribe(std::string const& topic) = 0;
  virtual void unsubscribe(std::string const& topic) = 0;
 
  Subscriber(const Subscriber&) = delete;
  Subscriber& operator=(const Subscriber&) = delete;
 
  Subscriber(Subscriber&&) = delete;
  Subscriber& operator=(Subscriber&&) = delete;
};
 
inline std::shared_ptr<Subscriber>
make_ipm_subscriber(std::string const& plugin_name)
{
  static cet::BasicPluginFactory bpf("duneIPM", "make");
  auto receiver_ptr = bpf.makePlugin<std::shared_ptr<Receiver>>(plugin_name);
  return std::dynamic_pointer_cast<Subscriber>(receiver_ptr);
}
 
} // namespace dunedaq::ipm
 
#endif // IPM_INCLUDE_IPM_SUBSCRIBER_HPP_