summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2014-08-18 16:08:53 +0100
committerSimon MacMullen <simon@rabbitmq.com>2014-08-18 16:08:53 +0100
commit7d26dce13c03f93e97413573ae37f7474aa05f6c (patch)
tree9e5961724a4e5edb0bc8d08e40f638f6f4f1cedb /src
parenta4121655d66ba9abf8d209d0fd45e1941046f7b4 (diff)
downloadrabbitmq-server-git-7d26dce13c03f93e97413573ae37f7474aa05f6c.tar.gz
Return 1 consumer.
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_channel.erl5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 472091d0d0..9da6ac448c 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -1109,14 +1109,15 @@ handle_method(#'exchange.unbind'{destination = DestinationNameBin,
SourceNameBin, exchange, DestinationNameBin, RoutingKey,
Arguments, #'exchange.unbind_ok'{}, NoWait, State);
-%% Note that all declares to these are effectively passive
+%% Note that all declares to these are effectively passive. If it
+%% exists it by definition has one consumer.
handle_method(#'queue.declare'{queue = <<"amq.rabbitmq.reply-to",
_/binary>> = QueueNameBin,
nowait = NoWait}, _,
State = #ch{virtual_host = VHost}) ->
QueueName = rabbit_misc:r(VHost, queue, QueueNameBin),
case declare_fast_reply_to(QueueNameBin) of
- exists -> return_queue_declare_ok(QueueName, NoWait, 0, 0, State);
+ exists -> return_queue_declare_ok(QueueName, NoWait, 0, 1, State);
not_found -> rabbit_misc:not_found(QueueName)
end;