ZeroMQ (im_zmq)
This module provides message transport over ZeroMQ, a scalable high-throughput messaging library.
The corresponding output module is om_zmq.
To examine the supported platforms, see the list of installer packages in the Available Modules chapter. |
Configuration
The im_zmq module accepts the following directives in addition to the common module directives. The Address, ConnectionType, Port, and SocketType directives are required.
- Address
-
This directive specifies the ZeroMQ socket address.
- ConnectionType
-
This mandatory directive specifies the underlying transport protocol. It may be one of the following:
TCP
,PGM
, orEPGM
.
- Port
-
This directive specifies the ZeroMQ socket port.
- SocketType
-
This mandatory directive defines the type of the socket to be used. It may be one of the following:
REP
,DEALER
,SUB
,XSUB
, orPULL
. This must be set toSUB
if ConnectionType is set toPGM
orEPGM
.
- Connect
-
If this boolean directive is set to TRUE, im_zmq will connect to the Address specified. If FALSE, im_zmq will bind to the Address and listen for connections. The default is FALSE.
- InputType
-
See the InputType directive in the list of common module directives. The default is
Dgram
.
- Interface
-
This directive specifies the ZeroMQ socket interface.
- SockOpt
-
This directive can be used to set ZeroMQ socket options. For example,
SockOpt ZMQ_SUBSCRIBE ANIMALS.CATS
. This directive may be used more than once to set multiple options.
Examples
This example configuration accepts ZeroMQ messages over TCP and writes them to file.
<Input zmq>
Module im_zmq
SocketType PULL
ConnectionType TCP
Address 10.0.0.1
Port 1415
</Input>
<Output file>
Module om_file
File "/var/log/zmq-messages.log"
</Output>
<Route zmq_to_file>
Path zmq => file
</Route>