diff options
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 7cc4a51a..49cf9764 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -166,11 +166,11 @@ terminate_delete(EmitStats, Reason, backing_queue = BQ}) -> fun (BQS) -> BQS1 = BQ:delete_and_terminate(Reason, BQS), - %% don't care if the internal delete doesn't return 'ok'. if EmitStats -> rabbit_event:if_enabled(State, #q.stats_timer, fun() -> emit_stats(State) end); true -> ok end, + %% don't care if the internal delete doesn't return 'ok'. rabbit_amqqueue:internal_delete(QName), BQS1 end. |