Struct Bind 

pub struct Bind;

This process listens on the endpoint: the side ZmqEndpoint::bind takes.

Examples

Routes for a queue this process binds retry on that queue and name no destination, because the listener takes the copies:

use std::time::Duration;

use ruststream_zeromq::Bind;
use ruststream_zeromq::queue::prelude::*;
use serde::Deserialize;

#[derive(Deserialize)]
struct Job {
    id: u64,
}

#[subscriber("jobs")]
async fn work(job: &Job) -> HandlerOutcome {
    if job.id == 0 {
        return HandlerOutcome::retry_after(Duration::from_secs(30));
    }
    HandlerOutcome::ack()
}

fn routes() -> impl RouterDef<ZmqQueue<Bind>> {
    Router::<ZmqQueue<Bind>>::new()
        .include(work)
        .max_attempts(nonzero!(5u32))
        .out_retry(Publish)
        .build()
}

#[ruststream::app]
fn app() -> impl App {
    RustStream::new(AppInfo::new("worker", "0.1.0")).with_broker(
        ZmqQueue::new(ZmqEndpoint::bind("tcp://0.0.0.0:5555")),
        |b| {
            b.include_router(routes());
        },
    )
}

Trait Implementations

impl Clone for Bind

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Bind

impl Debug for Bind

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

Formats the value using the given formatter.

impl Default for Bind

fn default() -> Self

Returns the “default value” for a type.

impl EndpointRole for Bind

impl Eq for Bind

impl Hash for Bind

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for Bind

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for Bind