Struct lapin_futures::channel::Channel

pub struct Channel<T> {
    pub transport: Arc<Mutex<AMQPTransport<T>>>,
    pub id: u16,
}

Channel provides methods to act on a channel, such as managing queues

Fields

transport: Arc<Mutex<AMQPTransport<T>>>

id: u16

Methods

impl<T: AsyncRead + AsyncWrite + 'static> Channel<T>

fn queue_declare(&self, name: &str) -> Box<Future<Item=(), Error=Error>>

creates a queue

returns a future that resolves once the queue is available

WARNING: this method cannot pass custom queue_declare arguments yet

fn basic_publish(&self,
                 queue: &str,
                 payload: &[u8])
                 -> Box<Future<Item=(), Error=Error>>

publishes a message on a queue

WARNING: does not handle chunking of the content for now

fn basic_consume(&self,
                 queue: &str,
                 consumer_tag: &str)
                 -> Box<Future<Item=Consumer<T>, Error=Error>>

creates a consumer stream

returns a future of a Consumer that resolves once the method succeeds

Consumer implements futures::Stream, so it can be used with any of the usual combinators

fn basic_ack(&self, delivery_tag: u64) -> Box<Future<Item=(), Error=Error>>

acks a message

fn basic_reject(&self,
                delivery_tag: u64,
                requeue: bool)
                -> Box<Future<Item=(), Error=Error>>

rejects a message

fn queue_purge(&self, name: &str) -> Box<Future<Item=(), Error=Error>>

purges a queue

Trait Implementations

impl<T: Clone> Clone for Channel<T>

fn clone(&self) -> Channel<T>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.