Struct lapin_async::channel::Channel

pub struct Channel {
    pub status: ChannelStatus,
    pub acknowledgements: Acknowledgements,
    pub replies: Replies,
    pub requests: Requests,
    pub queues: Queues,
    pub generated_names: GeneratedNames,
    // some fields omitted
}

Fields

status: ChannelStatus

acknowledgements: Acknowledgements

replies: Replies

requests: Requests

queues: Queues

generated_names: GeneratedNames

Methods

impl Channel

pub fn new(channel_id: u16, connection: Connection) -> Channel

pub fn set_closing(&self)

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

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

pub fn id(&self) -> u16

impl Channel

pub fn connection_start_ok(
    &self,
    client_properties: FieldTable,
    mechanism: &str,
    response: &str,
    locale: &str
) -> Result<Option<RequestId>, Error>

pub fn connection_tune_ok(
    &self,
    channel_max: ShortUInt,
    frame_max: LongUInt,
    heartbeat: ShortUInt
) -> Result<Option<RequestId>, Error>

pub fn connection_open(
    &self,
    virtual_host: &str
) -> Result<Option<RequestId>, Error>

pub fn connection_close(
    &self,
    reply_code: ShortUInt,
    reply_text: &str,
    class_id: ShortUInt,
    method_id: ShortUInt
) -> Result<Option<RequestId>, Error>

pub fn connection_close_ok(&self) -> Result<Option<RequestId>, Error>

pub fn connection_blocked(
    &self,
    reason: &str
) -> Result<Option<RequestId>, Error>

pub fn connection_unblocked(&self) -> Result<Option<RequestId>, Error>

pub fn channel_open(&self) -> Result<Option<RequestId>, Error>

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

pub fn channel_flow_ok(
    &self,
    options: ChannelFlowOkOptions
) -> Result<Option<RequestId>, Error>

pub fn channel_close(
    &self,
    reply_code: ShortUInt,
    reply_text: &str,
    class_id: ShortUInt,
    method_id: ShortUInt
) -> Result<Option<RequestId>, Error>

pub fn channel_close_ok(&self) -> Result<Option<RequestId>, Error>

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

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

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

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

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

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

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

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

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

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

pub fn basic_qos(
    &self,
    prefetch_count: ShortUInt,
    options: BasicQosOptions
) -> Result<Option<RequestId>, Error>

pub fn basic_consume(
    &self,
    queue: &str,
    consumer_tag: &str,
    options: BasicConsumeOptions,
    arguments: FieldTable,
    subscriber: Box<dyn ConsumerSubscriber>
) -> Result<Option<RequestId>, Error>

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

pub fn basic_cancel_ok(
    &self,
    consumer_tag: &str
) -> Result<Option<RequestId>, Error>

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

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

pub fn basic_ack(
    &self,
    delivery_tag: LongLongUInt,
    options: BasicAckOptions
) -> Result<Option<RequestId>, Error>

pub fn basic_reject(
    &self,
    delivery_tag: LongLongUInt,
    options: BasicRejectOptions
) -> Result<Option<RequestId>, Error>

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

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

pub fn basic_nack(
    &self,
    delivery_tag: LongLongUInt,
    options: BasicNackOptions
) -> Result<Option<RequestId>, Error>

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

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

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

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

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.