diff options
| author | Michael Klishin <michael@rabbitmq.com> | 2014-06-16 19:08:00 +0400 |
|---|---|---|
| committer | Michael Klishin <michael@rabbitmq.com> | 2014-06-16 19:08:00 +0400 |
| commit | 856ee85dcfef3c34c0daea119a4a21780fa64d43 (patch) | |
| tree | 7adfa94abd019256fa4d4dbcf3d771c378bc79de | |
| parent | cb2937e873e5fc2e2c7395edc0127e659177b705 (diff) | |
| download | rabbitmq-server-git-856ee85dcfef3c34c0daea119a4a21780fa64d43.tar.gz | |
Cover passive = false case
| -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, |