diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-08-18 16:08:53 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-08-18 16:08:53 +0100 |
| commit | 7d26dce13c03f93e97413573ae37f7474aa05f6c (patch) | |
| tree | 9e5961724a4e5edb0bc8d08e40f638f6f4f1cedb | |
| parent | a4121655d66ba9abf8d209d0fd45e1941046f7b4 (diff) | |
| download | rabbitmq-server-git-7d26dce13c03f93e97413573ae37f7474aa05f6c.tar.gz | |
Return 1 consumer.
| -rw-r--r-- | src/rabbit_channel.erl | 5 |
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; |
