diff options
| -rw-r--r-- | src/rabbit_amqqueue.erl | 3 | ||||
| -rw-r--r-- | src/rabbit_queue_collector.erl | 4 |
2 files changed, 4 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 4f06630b90..7c20f67dc8 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -463,7 +463,8 @@ stat(#amqqueue{pid = QPid}) -> delegate_call(QPid, stat). delete_immediately(QPids) -> - [gen_server2:cast(QPid, delete_immediately) || QPid <- QPids]. + [gen_server2:cast(QPid, delete_immediately) || QPid <- QPids], + ok. delete(#amqqueue{ pid = QPid }, IfUnused, IfEmpty) -> delegate_call(QPid, {delete, IfUnused, IfEmpty}). diff --git a/src/rabbit_queue_collector.erl b/src/rabbit_queue_collector.erl index 6ebde2aab5..be13b7f9df 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; - _ -> rabbit_amqqueue:delete_immediately(QPid) + _ -> ok = rabbit_amqqueue:delete_immediately(QPid) end, {reply, ok, State#state{monitors = pmon:monitor(QPid, QMons)}}; @@ -67,7 +67,7 @@ handle_call(delete_all, From, State = #state{monitors = QMons, delete_from = undefined}) -> case pmon:monitored(QMons) of [] -> {reply, ok, State#state{delete_from = From}}; - QPids -> rabbit_amqqueue:delete_immediately(QPids), + QPids -> ok = rabbit_amqqueue:delete_immediately(QPids), {noreply, State#state{delete_from = From}} end. |