Struct lapin_futures::channel::Channel [] [src]

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



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

creates a queue

returns a future that resolves once the queue is available

the mandatory and ìmmediate options can be set to true, but the return message will not be handled

publishes a message on a queue

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

acks a message

rejects a message

acks a message

purges a queue

Trait Implementations

impl<T> Clone for Channel<T>

Returns a copy of the value. Read more

Performs copy-assignment from source. Read more