diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-04-09 13:05:35 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-04-09 13:05:35 +0100 |
| commit | dd2b0da635540a52e22df69a4ff0cc3118f1ba3d (patch) | |
| tree | 622883dc179b0514467a6ab093b48a084f641891 | |
| parent | 8b9d9586c3fa13418a779b2202bbc3d4f1ed2164 (diff) | |
| download | rabbitmq-server-bug26103.tar.gz | |
Maybe simplerbug26103
| -rw-r--r-- | src/rabbit_dead_letter.erl | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/rabbit_dead_letter.erl b/src/rabbit_dead_letter.erl index c087736b..ec32e687 100644 --- a/src/rabbit_dead_letter.erl +++ b/src/rabbit_dead_letter.erl @@ -124,13 +124,13 @@ is_cycle(Queue, Deaths) -> %% no reject in it? case Rest of [] -> false; - [H|_] -> not lists:any( - fun ({table, D}) -> - {longstr, <<"rejected">>} =:= - rabbit_misc:table_lookup(D, <<"reason">>); - (_) -> - true - end, Cycle ++ [H]) + [H|_] -> lists:all( + fun ({table, D}) -> + {longstr, <<"rejected">>} =/= + rabbit_misc:table_lookup(D, <<"reason">>); + (_) -> + false + end, Cycle ++ [H]) end. log_cycle_once(Queues) -> |