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 | f364d25b259a8006dc6b3f4a91659e916761cf3a (patch) | |
| tree | 730442518e54b82a7888d2c64c1c0e7a6ac516b9 | |
| parent | 09cdf8e5ae8b7662931ae32082f60da20b946208 (diff) | |
| download | rabbitmq-server-git-f364d25b259a8006dc6b3f4a91659e916761cf3a.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 2d55cad4cd..4dd19bd373 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) -> |