Struct MyChannelCallback 

pub struct MyChannelCallback {
    pub channel_tx: UnboundedSender<ChannelCmd>,
}

Fields

channel_tx: UnboundedSender<ChannelCmd>

Trait Implementations

impl ChannelCallback for MyChannelCallback

fn close<'life0, 'life1, 'async_trait>( &'life0 mut self, channel: &'life1 Channel, close: CloseChannel, ) -> Pin<Box<dyn Future<Output = AMQPResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Callback to handle close channel request from server.

fn cancel<'life0, 'life1, 'async_trait>( &'life0 mut self, _channel: &'life1 Channel, _cancel: Cancel, ) -> Pin<Box<dyn Future<Output = AMQPResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Callback to handle server’s request to cancel the consumer of current channel.

fn flow<'life0, 'life1, 'async_trait>( &'life0 mut self, _channel: &'life1 Channel, _active: bool, ) -> Pin<Box<dyn Future<Output = AMQPResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Callback to handle server’s flow request to pause or restart the flow of sending content data.

fn publish_ack<'life0, 'life1, 'async_trait>( &'life0 mut self, _channel: &'life1 Channel, ack: Ack, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Callback to handle ack indication from server.

fn publish_nack<'life0, 'life1, 'async_trait>( &'life0 mut self, _channel: &'life1 Channel, nack: Nack, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Callback to handle nack indication from server.

fn publish_return<'life0, 'life1, 'async_trait>( &'life0 mut self, _channel: &'life1 Channel, _ret: Return, _basic_properties: BasicProperties, _content: Vec<u8>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Callback to handle return indication with undeliverable message from server.