amts_prelude/
nats_client.rs

1use nats::Connection;
2
3///Simple NATS wrapper
4pub struct NatsClient {
5    pub client: Connection,
6}
7
8impl NatsClient {
9    ///connect to a NATS server and obtain a client
10    pub fn new(addr: &str) -> Self {
11        if let Ok(nc) = nats::connect(addr) {
12            return NatsClient { client: nc };
13        } else {
14            panic!("Failed to connect to NATS");
15        }
16    }
17
18    ///Obtain a NATS connection from the client
19    pub fn connection(&self) -> Connection {
20        return self.client.clone();
21    }
22}

amts_prelude/nats_client.rs

amts_prelude/
nats_client.rs