Struct ZmqQueuePublisher 

pub struct ZmqQueuePublisher { /* private fields */ }

Publishes into the queue over a lazily attached PUSH socket.

On an endpoint a subscription of this service bound, the socket dials that subscription, so a publish reaches it and nothing else: one under the subscription’s own name (a retry copy, a job the service feeds itself) is sent, and one under any other name returns ZmqError::Send rather than arriving at the subscription as its next delivery. On an endpoint a subscription of this service dials, the peer there only pushes, so every publish returns ZmqError::Send naming that subscription.

Trait Implementations

impl Clone for ZmqQueuePublisher

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ZmqQueuePublisher

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Publisher for ZmqQueuePublisher

type Payload = Take

A frame owns its bytes: the payload becomes the message’s third frame and the socket keeps it until the send completes.

type Options = ()

ZMTP carries no per-message setting: a send takes the frames and nothing else, so there is nothing for a call site to adjust. See the crate documentation.

async fn publish( &self, msg: OutgoingMessage<'_, BytesMut>, _options: Option<&Self::Options>, ) -> Result<(), Self::Error>

Cancel safety

Cancel-safe. A publish dropped before the socket takes its message sends nothing. One dropped mid-send, while the peer applies back-pressure, leaves its message with the publisher: the next publish through it or a clone completes that send before its own, and a failure of it is logged against its name.

type Error = ZmqError

The error type returned by publish.

fn base_headers(&self) -> Option<&HeaderMap>

The headers this publisher contributes to every message it sends, underneath whatever the message itself names.