Struct ConnectedZmqQueue 

pub struct ConnectedZmqQueue { /* private fields */ }

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

Implementations

impl ConnectedZmqQueue

pub fn bound_address(&self) -> Option<String>

The address a local subscription resolved by binding (useful with an ephemeral tcp://...:0 endpoint); None until a subscription has bound.

pub fn publisher(&self) -> ZmqQueuePublisher

A publisher from the connected form.

Trait Implementations

impl ConnectedBroker for ConnectedZmqQueue

type Error = ZmqError

The error type returned by connected-broker operations.

type Closed = ()

The terminal witness returned by shutdown.

async fn shutdown(self) -> Result<(), Self::Error>

Closes the broker connection, flushing in-flight publishes and stopping background tasks, consuming the connected form.

impl Debug for ConnectedZmqQueue

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

Formats the value using the given formatter.

impl DefaultPublish for ConnectedZmqQueue

type Policy = ZmqQueuePublish

The broker’s plain publish policy, constructible with its defaults.

impl PublishPolicy<ConnectedZmqQueue> for ZmqQueuePublish

type Live = ZmqQueuePublisher

The live form this policy pairs into: a Publisher for a leaf policy, or the live wiring form for a combinator stack (a typed publisher over a policy pairs into the same typed publisher over the live leaf).

async fn pair( self, connected: &ConnectedZmqQueue, ) -> Result<Self::Live, PairError>

Pairs the policy with a connected broker, producing the live publisher.

impl Subscribe for ConnectedZmqQueue

type Subscriber = ZmqSubscriber

The subscriber type opened by a by-name subscription.

async fn subscribe(&self, name: &str) -> Result<Self::Subscriber, Self::Error>

Opens a subscription to name, producing this broker’s Subscriber.