diff options
| -rw-r--r-- | src/rabbit_queue_collector.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_queue_collector.erl b/src/rabbit_queue_collector.erl index be13b7f9..6dad01cc 100644 --- a/src/rabbit_queue_collector.erl +++ b/src/rabbit_queue_collector.erl @@ -59,7 +59,7 @@ handle_call({register, QPid}, _From, State = #state{monitors = QMons, delete_from = Deleting}) -> case Deleting of undefined -> ok; - _ -> ok = rabbit_amqqueue:delete_immediately(QPid) + _ -> ok = rabbit_amqqueue:delete_immediately([QPid]) end, {reply, ok, State#state{monitors = pmon:monitor(QPid, QMons)}}; |