diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-02-06 17:31:27 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-02-06 17:31:27 +0000 |
| commit | deca1270111b0cac2e7a8afb2105b9b65951d407 (patch) | |
| tree | 663edb3b1b243c76cb4487772c4e15f2f7d4d893 /src | |
| parent | 6f61770dcc3a38fe20b8db06723671a7bc65018b (diff) | |
| download | rabbitmq-server-git-deca1270111b0cac2e7a8afb2105b9b65951d407.tar.gz | |
Only delete queues for which no HA policy exists.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 352dea0737..04457ed07f 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -596,8 +596,10 @@ forget_all_durable(Node) -> #amqqueue{_ = '_'}, write), [rabbit_binding:process_deletions( internal_delete1(Name)) || - #amqqueue{name = Name, pid = Pid} <- Qs, - node(Pid) =:= Node], + #amqqueue{name = Name, pid = Pid} = Q <- Qs, + node(Pid) =:= Node, + rabbit_policy:get(<<"ha-mode">>, Q) + =:= {error, not_found}], ok end), ok. |