Struct RabbitMqChannel

pub struct RabbitMqChannel { /* private fields */ }

lapin::Channel wrapper which maintains a ref counter to the channels underlying connection

Methods from Deref<Target = Channel>

pub fn status(&self) -> &ChannelStatus

pub fn on_error<E>(&self, handler: E)

where E: FnMut(Error) + Send + 'static,

pub fn id(&self) -> u16

pub async fn close( &self, reply_code: u16, reply_text: &str, ) -> Result<(), Error>

pub async fn basic_consume( &self, queue: &str, consumer_tag: &str, options: BasicConsumeOptions, arguments: FieldTable, ) -> Result<Consumer, Error>

pub async fn basic_get( &self, queue: &str, options: BasicGetOptions, ) -> Result<Option<BasicGetMessage>, Error>

pub async fn exchange_declare( &self, exchange: &str, kind: ExchangeKind, options: ExchangeDeclareOptions, arguments: FieldTable, ) -> Result<(), Error>

pub async fn wait_for_confirms(&self) -> Result<Vec<BasicReturnMessage>, Error>

pub async fn basic_qos( &self, prefetch_count: u16, options: BasicQosOptions, ) -> Result<(), Error>

pub async fn basic_cancel( &self, consumer_tag: &str, options: BasicCancelOptions, ) -> Result<(), Error>

pub async fn basic_publish( &self, exchange: &str, routing_key: &str, options: BasicPublishOptions, payload: &[u8], properties: AMQPProperties, ) -> Result<PublisherConfirm, Error>

pub async fn basic_ack( &self, delivery_tag: u64, options: BasicAckOptions, ) -> Result<(), Error>

pub async fn basic_reject( &self, delivery_tag: u64, options: BasicRejectOptions, ) -> Result<(), Error>

pub async fn basic_recover_async( &self, options: BasicRecoverAsyncOptions, ) -> Result<(), Error>

pub async fn basic_recover( &self, options: BasicRecoverOptions, ) -> Result<(), Error>

pub async fn basic_nack( &self, delivery_tag: u64, options: BasicNackOptions, ) -> Result<(), Error>

pub async fn channel_flow( &self, options: ChannelFlowOptions, ) -> Result<bool, Error>

pub async fn access_request( &self, realm: &str, options: AccessRequestOptions, ) -> Result<(), Error>

pub async fn exchange_delete( &self, exchange: &str, options: ExchangeDeleteOptions, ) -> Result<(), Error>

Delete an exchange

pub async fn exchange_bind( &self, destination: &str, source: &str, routing_key: &str, options: ExchangeBindOptions, arguments: FieldTable, ) -> Result<(), Error>

pub async fn exchange_unbind( &self, destination: &str, source: &str, routing_key: &str, options: ExchangeUnbindOptions, arguments: FieldTable, ) -> Result<(), Error>

pub async fn queue_declare( &self, queue: &str, options: QueueDeclareOptions, arguments: FieldTable, ) -> Result<Queue, Error>

pub async fn queue_bind( &self, queue: &str, exchange: &str, routing_key: &str, options: QueueBindOptions, arguments: FieldTable, ) -> Result<(), Error>

pub async fn queue_purge( &self, queue: &str, options: QueuePurgeOptions, ) -> Result<u32, Error>

pub async fn queue_delete( &self, queue: &str, options: QueueDeleteOptions, ) -> Result<u32, Error>

pub async fn queue_unbind( &self, queue: &str, exchange: &str, routing_key: &str, arguments: FieldTable, ) -> Result<(), Error>

pub async fn tx_select(&self) -> Result<(), Error>

pub async fn tx_commit(&self) -> Result<(), Error>

pub async fn tx_rollback(&self) -> Result<(), Error>

pub async fn confirm_select( &self, options: ConfirmSelectOptions, ) -> Result<(), Error>

Trait Implementations

impl Deref for RabbitMqChannel

type Target = Channel

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for RabbitMqChannel

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl Drop for RabbitMqChannel

fn drop(&mut self)

Executes the destructor for this type.