diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-03-25 13:16:08 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-03-25 13:16:08 +0000 |
| commit | 076f5ad37213a503f4a7fa82d8e1d4a675062f84 (patch) | |
| tree | a99c3388dd38eacc60c05857dee5471e7f562aa5 /src/rabbit_channel.erl | |
| parent | 7dc15081000f8fe30167e3082001542b3e010015 (diff) | |
| download | rabbitmq-server-076f5ad37213a503f4a7fa82d8e1d4a675062f84.tar.gz | |
Our other consumer arg has an x- on it. Also, let's validate.
Diffstat (limited to 'src/rabbit_channel.erl')
| -rw-r--r-- | src/rabbit_channel.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index e59eca32..cafc507f 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1283,7 +1283,7 @@ 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 + case rabbit_misc:table_lookup(Args, <<"x-cancel-on-ha-failover">>) of {bool, true} -> remove; _ -> {recover, ConsumeSpec} end. |