10#include <framework/pcore/zmq/connections/ZMQConnection.h>
11#include <framework/pcore/zmq/utils/ZMQParent.h>
13#include <framework/pcore/zmq/messages/ZMQIdMessage.h>
37 ZMQSimpleConnection(
const std::string& monitoringAddress,
const std::shared_ptr<ZMQParent>& parent);
42 void handleEvent(std::unique_ptr<ZMQIdMessage> message);
ZMQConnectionOverSocket(const std::shared_ptr< ZMQParent > &parent)
Create a new instance passing the shared ZMQParent.
std::unique_ptr< ZMQIdMessage > handleIncomingData()
Block until there is an incoming message and return it as a ZMQIdMessage.
void handleEvent(std::unique_ptr< ZMQIdMessage > message)
Send the given message via the socket (the message includes the identity to send to)
ZMQSimpleConnection(const std::string &monitoringAddress, const std::shared_ptr< ZMQParent > &parent)
Create a new simple connection with a ZMQ_ROUTER socket binding to the given address.
Abstract base class for different kinds of events.