Struct Channel

pub struct Channel { /* private fields */ }

👎Deprecated: use lapin instead

Implementations

impl Channel

pub fn status(&self) -> &ChannelStatus

👎Deprecated: use lapin instead

pub fn id(&self) -> u16

👎Deprecated: use lapin instead

pub fn close(&self, reply_code: ShortUInt, reply_text: &str) -> Confirmation<()>

👎Deprecated: use lapin instead

pub fn basic_consume( &self, queue: &Queue, consumer_tag: &str, options: BasicConsumeOptions, arguments: FieldTable, subscriber: Box<dyn ConsumerSubscriber>, ) -> Confirmation<ShortString>

👎Deprecated: use lapin instead

pub fn wait_for_confirms(&self) -> Confirmation<Vec<BasicReturnMessage>>

👎Deprecated: use lapin instead

impl Channel

pub fn connection_blocked(&self, reason: &str) -> Confirmation<()>

👎Deprecated: use lapin instead

pub fn connection_unblocked(&self) -> Confirmation<()>

👎Deprecated: use lapin instead

pub fn channel_flow(&self, options: ChannelFlowOptions) -> Confirmation<Boolean>

👎Deprecated: use lapin instead

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

👎Deprecated: use lapin instead

pub fn exchange_declare( &self, exchange: &str, kind: &str, options: ExchangeDeclareOptions, arguments: FieldTable, ) -> Confirmation<()>

👎Deprecated: use lapin instead

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

👎Deprecated: use lapin instead

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

👎Deprecated: use lapin instead

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

👎Deprecated: use lapin instead

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

👎Deprecated: use lapin instead

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

👎Deprecated: use lapin instead

pub fn queue_purge( &self, queue: &str, options: QueuePurgeOptions, ) -> Confirmation<LongUInt>

👎Deprecated: use lapin instead

pub fn queue_delete( &self, queue: &str, options: QueueDeleteOptions, ) -> Confirmation<LongUInt>

👎Deprecated: use lapin instead

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

👎Deprecated: use lapin instead

pub fn basic_qos( &self, prefetch_count: ShortUInt, options: BasicQosOptions, ) -> Confirmation<()>

👎Deprecated: use lapin instead

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

👎Deprecated: use lapin instead

pub fn basic_publish( &self, exchange: &str, routing_key: &str, options: BasicPublishOptions, payload: Vec<u8>, properties: BasicProperties, ) -> Confirmation<()>

👎Deprecated: use lapin instead

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

👎Deprecated: use lapin instead

pub fn basic_ack( &self, delivery_tag: LongLongUInt, options: BasicAckOptions, ) -> Confirmation<()>

👎Deprecated: use lapin instead

pub fn basic_reject( &self, delivery_tag: LongLongUInt, options: BasicRejectOptions, ) -> Confirmation<()>

👎Deprecated: use lapin instead

pub fn basic_recover_async( &self, options: BasicRecoverAsyncOptions, ) -> Confirmation<()>

👎Deprecated: use lapin instead

pub fn basic_recover(&self, options: BasicRecoverOptions) -> Confirmation<()>

👎Deprecated: use lapin instead

pub fn basic_nack( &self, delivery_tag: LongLongUInt, options: BasicNackOptions, ) -> Confirmation<()>

👎Deprecated: use lapin instead

pub fn tx_select(&self) -> Confirmation<()>

👎Deprecated: use lapin instead

pub fn tx_commit(&self) -> Confirmation<()>

👎Deprecated: use lapin instead

pub fn tx_rollback(&self) -> Confirmation<()>

👎Deprecated: use lapin instead

pub fn confirm_select(&self, options: ConfirmSelectOptions) -> Confirmation<()>

👎Deprecated: use lapin instead

Trait Implementations

impl Clone for Channel

fn clone(&self) -> Channel

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Channel

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

Formats the value using the given formatter.