40 int rc =
zmq_bind (router,
"tcp://127.0.0.1:5560");
53 rc =
zmq_connect (dealer_one,
"tcp://127.0.0.1:5560");
58 rc =
zmq_send (dealer_one,
"Hello", 5, 0);
60 rc =
zmq_recv (router, buffer, 255, 0);
62 assert (buffer [0] ==
'X');
63 rc =
zmq_recv (router, buffer, 255, 0);
71 rc =
zmq_connect (dealer_two,
"tcp://127.0.0.1:5560");
75 rc =
zmq_send (dealer_two,
"Hello", 5, 0);
77 rc =
zmq_recv (router, buffer, 255, 0);
79 assert (buffer [0] ==
'X');
80 rc =
zmq_recv (router, buffer, 255, 0);
87 rc =
zmq_send (router,
"Hello", 5, 0);
95 rc =
zmq_recv (dealer_two, buffer, 255, 0);
ZMQ_EXPORT int zmq_setsockopt(void *s, int option, const void *optval, size_t optvallen)
#define ZMQ_ROUTER_HANDOVER
ZMQ_EXPORT void * zmq_ctx_new(void)
void setup_test_environment(void)
ZMQ_EXPORT int zmq_recv(void *s, void *buf, size_t len, int flags)
ZMQ_EXPORT void * zmq_socket(void *, int type)
ZMQ_EXPORT int zmq_connect(void *s, const char *addr)
ZMQ_EXPORT int zmq_close(void *s)
ZMQ_EXPORT int zmq_send(void *s, const void *buf, size_t len, int flags)
ZMQ_EXPORT int zmq_bind(void *s, const char *addr)
ZMQ_EXPORT int zmq_ctx_term(void *context)