diff options
| -rw-r--r-- | src/rabbit_channel.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index edbcb2eab7..6f244166b5 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -757,7 +757,8 @@ handle_method(#'queue.declare'{queue = QueueNameBin, %% the connection shuts down. ok = case Owner of none -> ok; - _ -> rabbit_queue_collector:register(CollectorPid, Q) + _ -> rabbit_queue_collector:register( + CollectorPid, Q) end, return_queue_declare_ok(QueueName, NoWait, 0, 0, State); {existing, _Q} -> |