NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
ZmqUtils.hpp File Reference
#include <Network/NetworkMessage.hpp>
#include <Operators/LogicalOperators/Network/NesPartition.hpp>
#include <Util/Logger/Logger.hpp>
#include <zmq.hpp>
Include dependency graph for ZmqUtils.hpp:
This graph shows which files directly or indirectly include this file:

Namespaces

 NES
 This exception represents a network error.
 
 NES::Network
 

Functions

template<typename MessageType , decltype(kZmqSendDefault) flags = kZmqSendDefault, typename... Arguments>
void NES::Network::sendMessage (zmq::socket_t &zmqSocket, Arguments &&... args)
 
template<typename MessageType , decltype(kZmqSendDefault) flags = kZmqSendDefault, typename... Arguments>
void NES::Network::sendMessageNoHeader (zmq::socket_t &zmqSocket, Arguments &&... args)
 
template<typename MessageType , typename... Arguments>
void NES::Network::sendMessageWithIdentity (zmq::socket_t &zmqSocket, zmq::message_t &zmqIdentity, Arguments &&... args)