diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2013-12-24 00:57:53 +0000 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2013-12-24 00:57:53 +0000 |
| commit | fc937677757e4fcf2a3ad0d8851282ba4f290d24 (patch) | |
| tree | d34be00346a5c259284c6dfce20971b9b2f04024 | |
| parent | d070eed911fe67b5cae760c5f3478a24082aa5ef (diff) | |
| download | rabbitmq-server-git-fc937677757e4fcf2a3ad0d8851282ba4f290d24.tar.gz | |
reduce distance to default
this got lost in the merge
| -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 |