diff options
| -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) -> |