azservicebus 0.25.1

An unofficial AMQP 1.0 rust client for Azure Service Bus
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

use super::SESSION_IDENTIFIER;

pub(crate) struct AmqpSession {
    pub(crate) identifier: u32,
    pub(crate) handle: fe2o3_amqp::session::SessionHandle<()>,
}

impl AmqpSession {
    pub(crate) fn new(handle: fe2o3_amqp::session::SessionHandle<()>) -> Self {
        Self {
            identifier: SESSION_IDENTIFIER.fetch_add(1, std::sync::atomic::Ordering::Relaxed),
            handle,
        }
    }
}