zmonitor man page

zmonitor — socket event monitor


//  Create new zmonitor actor instance to monitor a zsock_t socket:
//      zactor_t *monitor = zactor_new (zmonitor, mysocket);
//  Destroy zmonitor instance.
//      zactor_destroy (&monitor);
//  Enable verbose logging of commands and activity.
//      zstr_send (monitor, "VERBOSE");
//  Listen to monitor event type (zero or types, ending in NULL):
//      zstr_sendx (monitor, "LISTEN", type, ..., NULL);
//      Events:
//      ACCEPTED
//      CLOSED
//      ALL
//  Start monitor; after this, any further LISTEN commands are ignored.
//      zstr_send (monitor, "START");
//      zsock_wait (monitor);
//  Receive next monitor event:
//      zmsg_t *msg = zmsg_recv (monitor);
//  This is the zmonitor constructor as a zactor_fn; the argument can be
//  a zactor_t, zsock_t, or libzmq void * socket:
    zmonitor (zsock_t *pipe, void *sock);

//  Selftest
    zmonitor_test (bool verbose);
Please add '@interface' section in './../src/zmonitor.c'.


The zmonitor actor provides an API for obtaining socket events such as connected, listen, disconnected, etc. Socket events are only available for sockets connecting or bound to ipc:// and tcp:// endpoints.

This class wraps the ZMQ socket monitor API, see zmq_socket_monitor for details. Works on all versions of libzmq from 3.2 onwards. This class replaces zproxy_v2, and is meant for applications that use the CZMQ v3 API (meaning, zsock).


From zmonitor_test method.

zsock_t *client = zsock_new (ZMQ_DEALER);
assert (client);
zactor_t *clientmon = zactor_new (zmonitor, client);
assert (clientmon);
if (verbose)
    zstr_sendx (clientmon, "VERBOSE", NULL);
zstr_sendx (clientmon, "LISTEN", "LISTENING", "ACCEPTED", NULL);
zstr_sendx (clientmon, "START", NULL);
zsock_wait (clientmon);

zsock_t *server = zsock_new (ZMQ_DEALER);
assert (server);
zactor_t *servermon = zactor_new (zmonitor, server);
assert (servermon);
if (verbose)
    zstr_sendx (servermon, "VERBOSE", NULL);
zstr_sendx (servermon, "LISTEN", "CONNECTED", "DISCONNECTED", NULL);
zstr_sendx (servermon, "START", NULL);
zsock_wait (servermon);

//  Allow a brief time for the message to get there...
zmq_poll (NULL, 0, 200);

//  Check client is now listening
int port_nbr = zsock_bind (client, "tcp://*");
assert (port_nbr != -1);
s_assert_event (clientmon, "LISTENING");

//  Check server connected to client
zsock_connect (server, "tcp://", port_nbr);
s_assert_event (servermon, "CONNECTED");

//  Check client accepted connection
s_assert_event (clientmon, "ACCEPTED");

zactor_destroy (&clientmon);
zactor_destroy (&servermon);
zsock_destroy (&client);
zsock_destroy (&server);


The czmq manual was written by the authors in the Authors file.


Main web site:

Report bugs to the email <[1]>



Referenced By


12/31/2016 CZMQ 4.0.2 CZMQ Manual