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 | d5ed747a4fe894414f4bdcac9f0495c78bd855d8 (patch) | |
| tree | d34be00346a5c259284c6dfce20971b9b2f04024 | |
| parent | 9b9b80c8d5aaa20e5729d75f1afa7803b1a5d3fd (diff) | |
| download | rabbitmq-server-d5ed747a4fe894414f4bdcac9f0495c78bd855d8.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 f0121dc0..977a6f3d 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 |