Function amqpr_api::queue::bind::bind_queue_wait
[−]
[src]
pub fn bind_queue_wait<In, Out, E>(
income: In,
outcome: Out,
channel_id: u16,
option: BindQueueOption
) -> QueueBound<In, Out> where
In: Stream<Error = E>,
In::Item: Borrow<Frame>,
Out: Sink<SinkItem = Frame, SinkError = E>,
E: From<Error>,
Bind 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.