Struct ntex_amqp::SenderLink

pub struct SenderLink { /* private fields */ }

Implementations

impl SenderLink

pub fn id(&self) -> u32

Id of the sender link

pub fn name(&self) -> &ByteString

Name of the sender link

pub fn remote_handle(&self) -> Handle

Remote handle

pub fn session(&self) -> &Session

Reference to session

pub fn credit(&self) -> u32

Returns available send credit

pub async fn ready(&self) -> bool

Get notification when packet could be send to the peer.

Result indicates if connection is alive

pub fn is_closed(&self) -> bool

Check is link is closed

pub fn is_opened(&self) -> bool

Check link state

pub fn error(&self) -> Option<&AmqpProtocolError>

Check link error

pub fn delivery<T>(&self, body: T) -> DeliveryBuilder

where T: Into<TransferBody>,

Start delivery process

pub fn close(&self) -> impl Future<Output = Result<(), AmqpProtocolError>>

Close sender link

pub fn close_with_error<E>( &self, error: E ) -> impl Future<Output = Result<(), AmqpProtocolError>>

where Error: From<E>,

Close sender link with error

pub fn on_close(&self) -> Waiter

pub fn on_credit_update(&self) -> Waiter

Notify when credit get updated

After notification credit must be checked again, other waiters could consume it.

pub fn max_message_size(&self) -> Option<u32>

pub fn set_max_message_size(&self, value: u32)

Trait Implementations

impl Clone for SenderLink

fn clone(&self) -> SenderLink

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SenderLink

fn fmt(&self, fmt: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.