pub async fn message_bus_init_options(
    server: String,
    timeouts: TimeoutOptions,
) {
    let nc = NatsMessageBus::new(&server, BusOptions::new(), timeouts).await;
    NATS_MSG_BUS
        .set(nc)
        .ok()
        .expect("Expect to be initialised only once");
}
/// Initialise the Nats Message Bus with Options
Initialise the Nats Message Bus with Options
Initialise the Nats Message Bus with Options
pub async fn message_bus_init_options(
    server: String,
    timeouts: TimeoutOptions,
) {
    let nc = NatsMessageBus::new(&server, BusOptions::new(), timeouts).await;
    NATS_MSG_BUS
        .set(nc)
        .ok()
        .expect("Expect to be initialised only once");
}
pub async fn message_bus_init_options ( server : String , timeouts : TimeoutOptions , ) { let nc = NatsMessageBus :: new ( & server , BusOptions :: new ( ) , timeouts ) . await ; NATS_MSG_BUS . set ( nc ) . ok ( ) . expect ( " " ) ; }
Initialise the Nats Message Bus with Options
Initialise the Nats Message Bus with Options
server
String
timeouts
TimeoutOptions