diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-03-25 11:58:41 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-03-25 11:58:41 +0000 |
| commit | 2be4181c21818969df1a268f10754fd2bfcd8495 (patch) | |
| tree | d5a5e61e1199863f6fdf95fe8a0a8b727492bf1f | |
| parent | ccd7bc22c4bc2153ee42f71b6f229b1691a6c0d0 (diff) | |
| download | rabbitmq-server-git-2be4181c21818969df1a268f10754fd2bfcd8495.tar.gz | |
Swap the default value for cancel-on-ha-failover.
| -rw-r--r-- | src/rabbit_channel.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index e047db60af..e59eca32b8 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1284,8 +1284,8 @@ cancel_consumer(CTag, QName, State = #ch{consumer_mapping = CMap}) -> queue_down_consumer_action(CTag, CMap) -> {_, {_, _, _, Args} = ConsumeSpec} = dict:fetch(CTag, CMap), case rabbit_misc:table_lookup(Args, <<"cancel-on-ha-failover">>) of - {bool, false} -> {recover, ConsumeSpec}; - _ -> remove + {bool, true} -> remove; + _ -> {recover, ConsumeSpec} end. handle_delivering_queue_down(QPid, State = #ch{delivering_queues = DQ}) -> |