Module queue 

ZmqQueue: the PUSH/PULL pattern, competing consumers served in turn.

• ZmqQueue: ZmqQueue, connected into ConnectedZmqQueue, with read_ahead as its one setting beside the endpoint.
• Batches: ZmqSubscriber, the subscription of both one-way patterns, singly or in batches.
• Publishing: ZmqQueuePublish, offered as Publish by prelude, and its live ZmqQueuePublisher.
• Replies: results and replies through a queue on an endpoint of its own.
• out_retry: retry copies, back into a bound queue or to a place the mount names.

Re-exports

pub use self::ZmqQueuePublish as Publish;

Modules

prelude

The imports a routes file on the PUSH/PULL queue writes, in one glob: the framework’s prelude, the shared ZmqEndpoint, the broker ZmqQueue, and its publish policy as Publish.

Structs

ConnectedZmqQueue

The connected form of ZmqQueue; sockets attach per subscription and per publisher.

ZmqQueue

The PUSH/PULL queue: each message reaches one of the competing consumers.

ZmqQueuePublish

The publish policy for ZmqQueuePublisher.

ZmqQueuePublisher

Publishes into the queue over a PUSH socket of its own.

ZmqSubscriber

A subscription on one of the one-way patterns - PUSH/PULL or PUB/SUB - yielding ZmqMessages singly or in batches.