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 f0121dc010..977a6f3df9 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -1080,13 +1080,13 @@ handle_call({basic_cancel, ChPid, ConsumerTag, OkMsg}, _From, not_found -> reply(ok, State); Consumers1 -> - emit_consumer_deleted(ChPid, ConsumerTag, qname(State)), Holder1 = case Holder of {ChPid, ConsumerTag} -> none; _ -> Holder end, State1 = State#q{consumers = Consumers1, exclusive_consumer = Holder1}, + emit_consumer_deleted(ChPid, ConsumerTag, qname(State1)), notify_decorators( basic_cancel, [{consumer_tag, ConsumerTag}], State1), case should_auto_delete(State1) of |