34 fprintf (stderr,
"test_sub_forward running...\n");
42 int rc =
zmq_bind (xpub,
"tipc://{5560,0,0}");
46 rc =
zmq_bind (xsub,
"tipc://{5561,0,0}");
67 rc =
zmq_recv (xpub, buff,
sizeof (buff), 0);
80 rc =
zmq_recv (xsub, buff,
sizeof (buff), 0);
86 rc =
zmq_recv (sub, buff,
sizeof (buff), 0);
void msleep(int milliseconds)
ZMQ_EXPORT int zmq_setsockopt(void *s, int option, const void *optval, size_t optvallen)
ZMQ_EXPORT void * zmq_init(int io_threads)
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)