Function amqpr_api::queue::declare::declare_queue
[−]
[src]
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>,
Declare a queue synchronously.
That means we will wait to receive Declare-Ok
method after send Declare
method.