diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-09-13 14:50:06 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-09-13 14:50:06 +0100 |
| commit | 45f1fd2e31667967dd38cf84e32f5c5ace030dfa (patch) | |
| tree | 730442518e54b82a7888d2c64c1c0e7a6ac516b9 | |
| parent | 0a6653b14a1c47868ecaf695f919f35841d990f5 (diff) | |
| download | rabbitmq-server-45f1fd2e31667967dd38cf84e32f5c5ace030dfa.tar.gz | |
Oops, we completely broke HA there.
| -rw-r--r-- | src/rabbit_mirror_queue_misc.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_misc.erl b/src/rabbit_mirror_queue_misc.erl index 2d55cad4..4dd19bd3 100644 --- a/src/rabbit_mirror_queue_misc.erl +++ b/src/rabbit_mirror_queue_misc.erl @@ -257,8 +257,8 @@ policy(Policy, Q) -> module(#amqqueue{} = Q) -> case rabbit_policy:get(<<"ha-mode">>, Q) of - {ok, Mode} -> module(Mode); - _ -> not_mirrored + undefined -> not_mirrored; + Mode -> module(Mode) end; module(Mode) when is_binary(Mode) -> |