amqpr_api::queue::declare

Function declare_queue

Source 
pub fn declare_queue<S, E>(
    channel_id: u16,
    socket: S,
    option: DeclareQueueOption,
) -> QueueDeclared<S, E>
where
    S: Stream<Item = Frame, Error = E> + Sink<SinkItem = Frame, SinkError = E>,
    E: From<Error>,
Expand description

Declare a queue synchronously. That means we will wait to receive Declare-Ok method after send Declare method.