File zmq_borealis_helpers.hpp

Defines

ERR_CHK_ZMQ(x)

RECV_REPLY(x, y)

RECV_REQUEST(x, y)

RECV_PULSE(x, y)

SEND_REPLY(x, y, z)

SEND_REQUEST(x, y, z)

SEND_PULSE(x, y, z)

Functions

std::vector<zmq::socket_t> create_sockets(

zmq::context_t &context,

std::vector<std::string> identities,

std::string router_address

)

void send_string(

zmq::socket_t &socket,

std::string recv_iden,

std::string &data_msg

)

std::string recv_string(

zmq::socket_t &socket,

std::string sender_iden

)

void router(zmq::context_t &context, std::string router_address)