Skip to main content

Module queue

Module queue 

Source
Expand description

ZmqQueue: the PUSH/PULL pattern - competing consumers, round-robin.

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 descriptor ZmqQueue, and its publish policy as Publish.

Structs§

ConnectedZmqQueue
The connected form of ZmqQueue; sockets attach lazily per subscription and 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 lazily attached PUSH socket.
ZmqSubscriber
A subscription on one of the one-way patterns - PUSH/PULL or PUB/SUB - yielding ZmqMessages singly or in batches.