[−][src]Struct lapin_async::Channel
Deprecated:
use lapin instead
Methods
impl Channel
[src]
pub fn status(&self) -> &ChannelStatus
[src]
Deprecated:
use lapin instead
pub fn id(&self) -> u16
[src]
Deprecated:
use lapin instead
pub fn close(&self, reply_code: ShortUInt, reply_text: &str) -> Confirmation<()>
[src]
Deprecated:
use lapin instead
pub fn basic_consume(
&self,
queue: &Queue,
consumer_tag: &str,
options: BasicConsumeOptions,
arguments: FieldTable,
subscriber: Box<dyn ConsumerSubscriber>
) -> Confirmation<ShortString>
[src]
&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>>
[src]
Deprecated:
use lapin instead
impl Channel
[src]
pub fn connection_blocked(&self, reason: &str) -> Confirmation<()>
[src]
Deprecated:
use lapin instead
pub fn connection_unblocked(&self) -> Confirmation<()>
[src]
Deprecated:
use lapin instead
pub fn channel_flow(&self, options: ChannelFlowOptions) -> Confirmation<Boolean>
[src]
Deprecated:
use lapin instead
pub fn access_request(
&self,
realm: &str,
options: AccessRequestOptions
) -> Confirmation<()>
[src]
&self,
realm: &str,
options: AccessRequestOptions
) -> Confirmation<()>
Deprecated:
use lapin instead
pub fn exchange_declare(
&self,
exchange: &str,
kind: &str,
options: ExchangeDeclareOptions,
arguments: FieldTable
) -> Confirmation<()>
[src]
&self,
exchange: &str,
kind: &str,
options: ExchangeDeclareOptions,
arguments: FieldTable
) -> Confirmation<()>
Deprecated:
use lapin instead
pub fn exchange_delete(
&self,
exchange: &str,
options: ExchangeDeleteOptions
) -> Confirmation<()>
[src]
&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<()>
[src]
&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<()>
[src]
&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>
[src]
&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<()>
[src]
&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>
[src]
&self,
queue: &str,
options: QueuePurgeOptions
) -> Confirmation<LongUInt>
Deprecated:
use lapin instead
pub fn queue_delete(
&self,
queue: &str,
options: QueueDeleteOptions
) -> Confirmation<LongUInt>
[src]
&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<()>
[src]
&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<()>
[src]
&self,
prefetch_count: ShortUInt,
options: BasicQosOptions
) -> Confirmation<()>
Deprecated:
use lapin instead
pub fn basic_cancel(
&self,
consumer_tag: &str,
options: BasicCancelOptions
) -> Confirmation<()>
[src]
&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<()>
[src]
&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>>
[src]
&self,
queue: &str,
options: BasicGetOptions
) -> Confirmation<Option<BasicGetMessage>>
Deprecated:
use lapin instead
pub fn basic_ack(
&self,
delivery_tag: LongLongUInt,
options: BasicAckOptions
) -> Confirmation<()>
[src]
&self,
delivery_tag: LongLongUInt,
options: BasicAckOptions
) -> Confirmation<()>
Deprecated:
use lapin instead
pub fn basic_reject(
&self,
delivery_tag: LongLongUInt,
options: BasicRejectOptions
) -> Confirmation<()>
[src]
&self,
delivery_tag: LongLongUInt,
options: BasicRejectOptions
) -> Confirmation<()>
Deprecated:
use lapin instead
pub fn basic_recover_async(
&self,
options: BasicRecoverAsyncOptions
) -> Confirmation<()>
[src]
&self,
options: BasicRecoverAsyncOptions
) -> Confirmation<()>
Deprecated:
use lapin instead
pub fn basic_recover(&self, options: BasicRecoverOptions) -> Confirmation<()>
[src]
Deprecated:
use lapin instead
pub fn basic_nack(
&self,
delivery_tag: LongLongUInt,
options: BasicNackOptions
) -> Confirmation<()>
[src]
&self,
delivery_tag: LongLongUInt,
options: BasicNackOptions
) -> Confirmation<()>
Deprecated:
use lapin instead
pub fn tx_select(&self) -> Confirmation<()>
[src]
Deprecated:
use lapin instead
pub fn tx_commit(&self) -> Confirmation<()>
[src]
Deprecated:
use lapin instead
pub fn tx_rollback(&self) -> Confirmation<()>
[src]
Deprecated:
use lapin instead
pub fn confirm_select(&self, options: ConfirmSelectOptions) -> Confirmation<()>
[src]
Deprecated:
use lapin instead
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Channel
impl Send for Channel
impl Sync for Channel
impl Unpin for Channel
impl !UnwindSafe for Channel
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,