[−][src]Struct lapin::Channel
Methods
impl Channel
[src]
pub fn status(&self) -> &ChannelStatus
[src]
pub fn id(&self) -> u16
[src]
pub fn close(&self, reply_code: ShortUInt, reply_text: &str) -> Promise<()>
[src]
pub fn exchange_declare(
&self,
exchange: &str,
kind: ExchangeKind,
options: ExchangeDeclareOptions,
arguments: FieldTable
) -> Promise<()>
[src]
&self,
exchange: &str,
kind: ExchangeKind,
options: ExchangeDeclareOptions,
arguments: FieldTable
) -> Promise<()>
pub fn wait_for_confirms(&self) -> ConfirmationPromise<Vec<BasicReturnMessage>>
[src]
impl Channel
[src]
pub fn channel_flow(&self, options: ChannelFlowOptions) -> PromiseChain<Boolean>
[src]
pub fn access_request(
&self,
realm: &str,
options: AccessRequestOptions
) -> Promise<()>
[src]
&self,
realm: &str,
options: AccessRequestOptions
) -> Promise<()>
pub fn exchange_delete(
&self,
exchange: &str,
options: ExchangeDeleteOptions
) -> Promise<()>
[src]
&self,
exchange: &str,
options: ExchangeDeleteOptions
) -> Promise<()>
pub fn exchange_bind(
&self,
destination: &str,
source: &str,
routing_key: &str,
options: ExchangeBindOptions,
arguments: FieldTable
) -> Promise<()>
[src]
&self,
destination: &str,
source: &str,
routing_key: &str,
options: ExchangeBindOptions,
arguments: FieldTable
) -> Promise<()>
pub fn exchange_unbind(
&self,
destination: &str,
source: &str,
routing_key: &str,
options: ExchangeUnbindOptions,
arguments: FieldTable
) -> Promise<()>
[src]
&self,
destination: &str,
source: &str,
routing_key: &str,
options: ExchangeUnbindOptions,
arguments: FieldTable
) -> Promise<()>
pub fn queue_declare(
&self,
queue: &str,
options: QueueDeclareOptions,
arguments: FieldTable
) -> PromiseChain<Queue>
[src]
&self,
queue: &str,
options: QueueDeclareOptions,
arguments: FieldTable
) -> PromiseChain<Queue>
pub fn queue_bind(
&self,
queue: &str,
exchange: &str,
routing_key: &str,
options: QueueBindOptions,
arguments: FieldTable
) -> Promise<()>
[src]
&self,
queue: &str,
exchange: &str,
routing_key: &str,
options: QueueBindOptions,
arguments: FieldTable
) -> Promise<()>
pub fn queue_purge(
&self,
queue: &str,
options: QueuePurgeOptions
) -> PromiseChain<LongUInt>
[src]
&self,
queue: &str,
options: QueuePurgeOptions
) -> PromiseChain<LongUInt>
pub fn queue_delete(
&self,
queue: &str,
options: QueueDeleteOptions
) -> PromiseChain<LongUInt>
[src]
&self,
queue: &str,
options: QueueDeleteOptions
) -> PromiseChain<LongUInt>
pub fn queue_unbind(
&self,
queue: &str,
exchange: &str,
routing_key: &str,
arguments: FieldTable
) -> Promise<()>
[src]
&self,
queue: &str,
exchange: &str,
routing_key: &str,
arguments: FieldTable
) -> Promise<()>
pub fn basic_qos(
&self,
prefetch_count: ShortUInt,
options: BasicQosOptions
) -> Promise<()>
[src]
&self,
prefetch_count: ShortUInt,
options: BasicQosOptions
) -> Promise<()>
pub fn basic_consume(
&self,
queue: &str,
consumer_tag: &str,
options: BasicConsumeOptions,
arguments: FieldTable
) -> PromiseChain<Consumer>
[src]
&self,
queue: &str,
consumer_tag: &str,
options: BasicConsumeOptions,
arguments: FieldTable
) -> PromiseChain<Consumer>
pub fn basic_cancel(
&self,
consumer_tag: &str,
options: BasicCancelOptions
) -> Promise<()>
[src]
&self,
consumer_tag: &str,
options: BasicCancelOptions
) -> Promise<()>
pub fn basic_publish(
&self,
exchange: &str,
routing_key: &str,
options: BasicPublishOptions,
payload: Vec<u8>,
properties: BasicProperties
) -> PromiseChain<PublisherConfirm>
[src]
&self,
exchange: &str,
routing_key: &str,
options: BasicPublishOptions,
payload: Vec<u8>,
properties: BasicProperties
) -> PromiseChain<PublisherConfirm>
pub fn basic_get(
&self,
queue: &str,
options: BasicGetOptions
) -> PromiseChain<Option<BasicGetMessage>>
[src]
&self,
queue: &str,
options: BasicGetOptions
) -> PromiseChain<Option<BasicGetMessage>>
pub fn basic_ack(
&self,
delivery_tag: LongLongUInt,
options: BasicAckOptions
) -> Promise<()>
[src]
&self,
delivery_tag: LongLongUInt,
options: BasicAckOptions
) -> Promise<()>
pub fn basic_reject(
&self,
delivery_tag: LongLongUInt,
options: BasicRejectOptions
) -> Promise<()>
[src]
&self,
delivery_tag: LongLongUInt,
options: BasicRejectOptions
) -> Promise<()>
pub fn basic_recover_async(
&self,
options: BasicRecoverAsyncOptions
) -> Promise<()>
[src]
&self,
options: BasicRecoverAsyncOptions
) -> Promise<()>
pub fn basic_recover(&self, options: BasicRecoverOptions) -> Promise<()>
[src]
pub fn basic_nack(
&self,
delivery_tag: LongLongUInt,
options: BasicNackOptions
) -> Promise<()>
[src]
&self,
delivery_tag: LongLongUInt,
options: BasicNackOptions
) -> Promise<()>
pub fn tx_select(&self) -> Promise<()>
[src]
pub fn tx_commit(&self) -> Promise<()>
[src]
pub fn tx_rollback(&self) -> Promise<()>
[src]
pub fn confirm_select(&self, options: ConfirmSelectOptions) -> Promise<()>
[src]
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>,