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