Struct ntex_amqp::Session [−][src]
pub struct Session { /* fields omitted */ }
Implementations
pub fn build_sender_link<T: Into<ByteString>, U: Into<ByteString>>(
&self,
name: U,
address: T
) -> SenderLinkBuilder
pub fn build_sender_link<T: Into<ByteString>, U: Into<ByteString>>(
&self,
name: U,
address: T
) -> SenderLinkBuilder
Open sender link
pub fn build_receiver_link<T: Into<ByteString>, U: Into<ByteString>>(
&mut self,
name: U,
address: T
) -> ReceiverLinkBuilder
pub fn build_receiver_link<T: Into<ByteString>, U: Into<ByteString>>(
&mut self,
name: U,
address: T
) -> ReceiverLinkBuilder
Open receiver link
pub fn detach_receiver_link(
&mut self,
handle: Handle,
error: Option<Error>
) -> impl Future<Output = Result<(), AmqpProtocolError>>
pub fn detach_receiver_link(
&mut self,
handle: Handle,
error: Option<Error>
) -> impl Future<Output = Result<(), AmqpProtocolError>>
Detach receiver link
pub fn wait_disposition(
&mut self,
id: DeliveryNumber
) -> impl Future<Output = Result<Disposition, AmqpProtocolError>>
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Session
impl !UnwindSafe for Session
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more