Struct lapin::Channel [−][src]
pub struct Channel { /* fields omitted */ }
Implementations
pub fn basic_consume(
&self,
queue: &str,
consumer_tag: &str,
options: BasicConsumeOptions,
arguments: FieldTable
) -> PromiseChain<Consumer>
pub fn basic_get(
&self,
queue: &str,
options: BasicGetOptions
) -> PromiseChain<Option<BasicGetMessage>>
pub fn exchange_declare(
&self,
exchange: &str,
kind: ExchangeKind,
options: ExchangeDeclareOptions,
arguments: FieldTable
) -> Promise<()>
pub fn do_channel_close(
&self,
reply_code: ShortUInt,
reply_text: &str,
class_id: ShortUInt,
method_id: ShortUInt
) -> Promise<()>
pub fn do_exchange_declare(
&self,
exchange: &str,
kind: &str,
options: ExchangeDeclareOptions,
arguments: FieldTable,
exchange_kind: ExchangeKind
) -> PromiseChain<()>
Delete an exchange
pub fn exchange_bind(
&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<()>
pub fn queue_declare(
&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<()>
pub fn queue_delete(
&self,
queue: &str,
options: QueueDeleteOptions
) -> PromiseChain<LongUInt>
pub fn queue_unbind(
&self,
queue: &str,
exchange: &str,
routing_key: &str,
arguments: FieldTable
) -> Promise<()>
pub fn do_basic_consume(
&self,
queue: &str,
consumer_tag: &str,
options: BasicConsumeOptions,
arguments: FieldTable,
original: Option<Consumer>
) -> PromiseChain<Consumer>
pub fn basic_publish(
&self,
exchange: &str,
routing_key: &str,
options: BasicPublishOptions,
payload: Vec<u8>,
properties: BasicProperties
) -> PromiseChain<PublisherConfirm>
pub fn do_basic_get(
&self,
queue: &str,
options: BasicGetOptions,
original: Option<Pinky<Result<Option<BasicGetMessage>>>>
) -> PromiseChain<Option<BasicGetMessage>>
pub fn basic_reject(
&self,
delivery_tag: LongLongUInt,
options: BasicRejectOptions
) -> Promise<()>
pub fn basic_nack(
&self,
delivery_tag: LongLongUInt,
options: BasicNackOptions
) -> Promise<()>
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Channel
impl !UnwindSafe for Channel
Blanket Implementations
Mutably borrows from an owned value. Read more
Instruments this type with the provided Span
, returning an
Instrumented
wrapper. Read more