Function amqpr_api::queue::declare::declare_queue_wait
[−]
[src]
pub fn declare_queue_wait<In, Out, E>(
income: In,
outcome: Out,
channel_id: u16,
option: DeclareQueueOption
) -> QueueDeclaredWait<In, Out> where
In: Stream<Error = E>,
In::Item: Borrow<Frame>,
Out: 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.
If you want not to wait receiving, you should use declare_queue
instead.
This function ignores is_not_wait
flag of option.