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 detach_sender_link(
&mut self,
handle: Handle,
error: Option<Error>
) -> impl Future<Output = Result<(), AmqpProtocolError>>
pub fn detach_sender_link(
&mut self,
handle: Handle,
error: Option<Error>
) -> impl Future<Output = Result<(), AmqpProtocolError>>
Detach sender 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
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