nanomsg

Consumes messages via Nanomsg sockets (scalability protocols).

# Common config fields, showing default values
input:
nanomsg:
urls:
- tcp://*:5555
bind: true
socket_type: PULL
sub_filters: []

Currently only PULL and SUB sockets are supported.

Fields

urls

A list of URLs to connect to (or as). If an item of the list contains commas it will be expanded into multiple URLs.

Type: array
Default: ["tcp://*:5555"]

bind

Whether the URLs provided should be connected to, or bound as.

Type: bool
Default: true

socket_type

The socket type to use.

Type: string
Default: "PULL"
Options: PULL, SUB.

sub_filters

A list of subcription topic filters to use when consuming from a SUB socket. Specifying a single sub_filter of '' will subscribe to everything.

Type: array
Default: []

poll_timeout

The period to wait until a poll is abandoned and reattempted.

Type: string
Default: "5s"