zeromq 0.6.0

A native Rust implementation of ZeroMQ
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

mod async_helpers;

use zeromq::{proxy, Socket, XPubSocket, XSubSocket};

#[async_helpers::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    pretty_env_logger::try_init().ok();

    let mut frontend = XSubSocket::new();
    let mut backend = XPubSocket::new();

    let frontend_endpoint = frontend.bind("tcp://127.0.0.1:5557").await?;
    let backend_endpoint = backend.bind("tcp://127.0.0.1:5558").await?;

    println!("XSUB/XPUB proxy running");
    println!(
        "Upstream publishers or brokers connect to {}",
        frontend_endpoint
    );
    println!(
        "Downstream subscribers or brokers connect to {}",
        backend_endpoint
    );

    proxy(frontend, backend, None).await?;
    Ok(())
}