Struct ZmqQueue 

pub struct ZmqQueue { /* private fields */ }

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

Examples

use ruststream_zeromq::{ZmqEndpoint, ZmqQueue};

let consumer = ZmqQueue::new(ZmqEndpoint::bind("tcp://0.0.0.0:5555"));
let producer = ZmqQueue::new(ZmqEndpoint::connect("tcp://worker:5555"));

Implementations

impl ZmqQueue

pub fn new(endpoint: ZmqEndpoint) -> Self

Records the endpoint. No I/O.

pub fn publisher(&self) -> ZmqQueuePublisher

A publisher sharing this queue’s state; buildable before connect.

Trait Implementations

impl Broker for ZmqQueue

type Error = ZmqError

The error type returned by broker-level operations.

type Connected = ConnectedZmqQueue

The connected form of this broker: the typed witness that connect succeeded.

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

Establishes the connection to the broker, consuming the unconnected form.

fn bindable(self) -> Bindable<Self>

where Self: 'static,

Wraps the broker for publisher-token minting before registration: the returned Bindable hands out Bound tokens via its bind, and is itself what with_broker takes.

impl Clone for ZmqQueue

fn clone(&self) -> ZmqQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ZmqQueue

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

Formats the value using the given formatter.

impl DescribeServer for ZmqQueue

fn describe_server(&self) -> ServerSpec

Returns the server coordinates for this broker.