diff options
| -rw-r--r-- | src/rabbit_channel.erl | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index d35ad1a6bf..ee863a397a 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -992,7 +992,12 @@ handle_method(#'queue.declare'{queue = QueueNameBin, QueueName, fun (Q) -> ok = rabbit_amqqueue:assert_equivalence( Q, Durable, AutoDelete, Args, Owner), - rabbit_amqqueue:stat(Q) + case NoWait of + false -> + rabbit_amqqueue:stat(Q); + _ -> + {ok, 0, 0} + end end) of {ok, MessageCount, ConsumerCount} -> return_queue_declare_ok(QueueName, NoWait, MessageCount, |