Struct fe2o3_amqp::session::Session
source · pub struct Session { /* private fields */ }
Expand description
AMQP1.0 Session
§Begin a new Session with default configuration
ⓘ
use fe2o3_amqp::Session;
let session = Session::begin(&mut connection).await.unwrap();
§Default configuration
Field | Default Value |
---|---|
next_outgoing_id | 0 |
incoming_window | DEFAULT_WINDOW |
outgoing_window | DEFAULT_WINDOW |
handle_max | u32::MAX |
offered_capabilities | None |
desired_capabilities | None |
Properties | None |
§Customize configuration with Builder
The builder should be used if the user would like to customize the configuration for the session.
ⓘ
let session = Session::builder()
.handle_max(128)
.begin(&mut connection)
.await.unwrap();
Implementations§
source§impl Session
impl Session
sourcepub async fn begin(
conn: &mut ConnectionHandle<()>
) -> Result<SessionHandle<()>, BeginError>
Available on non-WebAssembly only.
pub async fn begin( conn: &mut ConnectionHandle<()> ) -> Result<SessionHandle<()>, BeginError>
Begins a new session with the default configurations
§Default configuration
Field | Default Value |
---|---|
next_outgoing_id | 0 |
incoming_window | DEFAULT_WINDOW |
outgoing_window | DEFAULT_WINDOW |
handle_max | u32::MAX |
offered_capabilities | None |
desired_capabilities | None |
Properties | None |
§Example
ⓘ
use fe2o3_amqp::Session;
let session = Session::begin(&mut connection).await.unwrap();
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for Session
impl Send for Session
impl Sync for Session
impl Unpin for Session
impl !UnwindSafe for Session
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more