Subscriber.hpp File Reference

#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>

Include dependency graph for Subscriber.hpp:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
class	dunedaq::ipm::Subscriber

Namespaces
namespace	dunedaq
	Including Qt Headers.
namespace	dunedaq::ipm
	An ERS Error indicating that an exception was thrown from ZMQ while performing an operation.

Functions
std::shared_ptr< Subscriber >	dunedaq::ipm::make_ipm_subscriber (std::string const &plugin_name)

Detailed Description

Subscriber Class Interface

Subscriber defines the interface of objects which can receive messages between processes that are sent to topics that have been subscribed to. Subscribers can also be Receivers

Implementor of this interface is required to:

• Implement the protected virtual receive_ function, called by public non-virtual receive
• Implement the public virtual can_receive function
• Implement the public virtual connect_for_receives function
• Implement the public virtual subscribe function
• Implement the public virtual unsubscribe function

And is encouraged to:

• Meaningfully implement the timeout feature in receive_, and have it throw the ReceiveTimeoutExpired exception if it occurs

This is part of the DUNE DAQ Application Framework, copyright 2020. Licensing/copyright details are in the COPYING file that you should have received with this code.

Definition in file Subscriber.hpp.