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 | e0a5225cb21c47986e2546b67e344393bea6a519 (patch) | |
| tree | 7adfa94abd019256fa4d4dbcf3d771c378bc79de | |
| parent | e488e880996be457068b84f9954ece05d08425aa (diff) | |
| download | rabbitmq-server-e0a5225cb21c47986e2546b67e344393bea6a519.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 d35ad1a6..ee863a39 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, |