stan 0.0.16

NATS Streaming client based on official NATS rust client
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
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

use std::{io, str::from_utf8};
mod utils;
use logtest::Logger;

#[test]
fn test_with_queue_group() -> io::Result<()> {
    let server = utils::server()?;
    let nats_url = &format!("localhost:{}", server.port);
    let nc = nats::connect(nats_url)?;
    let sc = stan::connect(nc, "test-cluster", "rust-client-1")?;
    let queue_group = "queue-group-name";
    let mut logger = Logger::start();

    for _ in 0..4 {
        // fork 4 subscriptions on the same queue group
        sc.subscribe(
            "foo",
            stan::SubscriptionConfig {
                queue_group: Some(queue_group),
                ..Default::default()
            },
        )?.with_handler(|msg| {
            log::info!("received: {}", from_utf8(&msg.data).unwrap());
            Ok(())
        });
    }

    sc.publish("foo", "hello from rust 1")?;
    sc.publish("foo", "hello from rust 2")?;
    sc.publish("foo", "hello from rust 3")?;
    sc.publish("foo", "hello from rust 4")?;

    sc.subscribe("foo", stan::SubscriptionConfig{
        start: stan::SubscriptionStart::LastReceived,
        ..Default::default()
    })?.next();

    assert_eq!(logger.pop().unwrap().args(), "received: hello from rust 1");
    assert_eq!(logger.pop().unwrap().args(), "received: hello from rust 2");
    assert_eq!(logger.pop().unwrap().args(), "received: hello from rust 3");
    assert_eq!(logger.pop().unwrap().args(), "received: hello from rust 4");
    Ok(())
}