1ZMONITOR(3)                       CZMQ Manual                      ZMONITOR(3)
2
3
4

NAME

6       zmonitor - Class for socket event monitor
7

SYNOPSIS

9       //  Create new zmonitor actor instance to monitor a zsock_t socket:
10       //
11       //      zactor_t *monitor = zactor_new (zmonitor, mysocket);
12       //
13       //  Destroy zmonitor instance.
14       //
15       //      zactor_destroy (&monitor);
16       //
17       //  Enable verbose logging of commands and activity.
18       //
19       //      zstr_send (monitor, "VERBOSE");
20       //
21       //  Listen to monitor event type (zero or types, ending in NULL):
22       //      zstr_sendx (monitor, "LISTEN", type, ..., NULL);
23       //
24       //      Events:
25       //      CONNECTED
26       //      CONNECT_DELAYED
27       //      CONNECT_RETRIED
28       //      LISTENING
29       //      BIND_FAILED
30       //      ACCEPTED
31       //      ACCEPT_FAILED
32       //      CLOSED
33       //      CLOSE_FAILED
34       //      DISCONNECTED
35       //      MONITOR_STOPPED
36       //      ALL
37       //
38       //  Start monitor; after this, any further LISTEN commands are ignored.
39       //
40       //      zstr_send (monitor, "START");
41       //      zsock_wait (monitor);
42       //
43       //  Receive next monitor event:
44       //
45       //      zmsg_t *msg = zmsg_recv (monitor);
46       //
47       //  This is the zmonitor constructor as a zactor_fn; the argument can be
48       //  a zactor_t, zsock_t, or libzmq void * socket:
49       CZMQ_EXPORT void
50           zmonitor (zsock_t *pipe, void *sock);
51
52       //  Selftest
53       CZMQ_EXPORT void
54           zmonitor_test (bool verbose);
55       Please add '@interface' section in './../src/zmonitor.c'.
56

DESCRIPTION

58       The zmonitor actor provides an API for obtaining socket events such as
59       connected, listen, disconnected, etc. Socket events are only available
60       for sockets connecting or bound to ipc:// and tcp:// endpoints.
61
62       This class wraps the ZMQ socket monitor API, see zmq_socket_monitor for
63       details. Works on all versions of libzmq from 3.2 onwards. This class
64       replaces zproxy_v2, and is meant for applications that use the CZMQ v3
65       API (meaning, zsock).
66

EXAMPLE

68       From zmonitor_test method.
69
70           zsock_t *client = zsock_new (ZMQ_DEALER);
71           assert (client);
72           zactor_t *clientmon = zactor_new (zmonitor, client);
73           assert (clientmon);
74           if (verbose)
75               zstr_sendx (clientmon, "VERBOSE", NULL);
76           zstr_sendx (clientmon, "LISTEN", "LISTENING", "ACCEPTED", NULL);
77           #if defined (ZMQ_EVENT_HANDSHAKE_SUCCEED)
78           zstr_sendx (clientmon, "LISTEN", "HANDSHAKE_SUCCEED", NULL);
79           #endif
80           #if defined (ZMQ_EVENT_HANDSHAKE_SUCCEEDED)
81           zstr_sendx (clientmon, "LISTEN", "HANDSHAKE_SUCCEEDED", NULL);
82           #endif
83           zstr_sendx (clientmon, "START", NULL);
84           zsock_wait (clientmon);
85
86           zsock_t *server = zsock_new (ZMQ_DEALER);
87           assert (server);
88           zactor_t *servermon = zactor_new (zmonitor, server);
89           assert (servermon);
90           if (verbose)
91               zstr_sendx (servermon, "VERBOSE", NULL);
92           zstr_sendx (servermon, "LISTEN", "CONNECTED", "DISCONNECTED", NULL);
93           zstr_sendx (servermon, "START", NULL);
94           zsock_wait (servermon);
95
96           //  Allow a brief time for the message to get there...
97           zmq_poll (NULL, 0, 200);
98
99           //  Check client is now listening
100           int port_nbr = zsock_bind (client, "tcp://127.0.0.1:*");
101           assert (port_nbr != -1);
102           s_assert_event (clientmon, "LISTENING");
103
104           //  Check server connected to client
105           zsock_connect (server, "tcp://127.0.0.1:%d", port_nbr);
106           s_assert_event (servermon, "CONNECTED");
107
108           //  Check client accepted connection
109           s_assert_event (clientmon, "ACCEPTED");
110           #if defined (ZMQ_EVENT_HANDSHAKE_SUCCEED)
111           s_assert_event (clientmon, "HANDSHAKE_SUCCEED");
112           #endif
113           #if defined (ZMQ_EVENT_HANDSHAKE_SUCCEEDED)
114           s_assert_event (clientmon, "HANDSHAKE_SUCCEEDED");
115           #endif
116
117           zactor_destroy (&clientmon);
118           zactor_destroy (&servermon);
119           zsock_destroy (&client);
120           zsock_destroy (&server);
121           #endif
122
123           #if defined (__WINDOWS__)
124           zsys_shutdown();
125           #endif
126
127

AUTHORS

129       The czmq manual was written by the authors in the AUTHORS file.
130

RESOURCES

132       Main web site:
133
134       Report bugs to the email <zeromq-dev@lists.zeromq.org[1]>
135
137       Copyright (c) the Contributors as noted in the AUTHORS file. This file
138       is part of CZMQ, the high-level C binding for 0MQ:
139       http://czmq.zeromq.org. This Source Code Form is subject to the terms
140       of the Mozilla Public License, v. 2.0. If a copy of the MPL was not
141       distributed with this file, You can obtain one at
142       http://mozilla.org/MPL/2.0/. LICENSE included with the czmq
143       distribution.
144

NOTES

146        1. zeromq-dev@lists.zeromq.org
147           mailto:zeromq-dev@lists.zeromq.org
148
149
150
151CZMQ 4.1.1                        07/24/2019                       ZMONITOR(3)
Impressum