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 | f9e5f0632d5c5c2a586fbb5b7f29e7d040cf25bf (patch) | |
| tree | 622883dc179b0514467a6ab093b48a084f641891 | |
| parent | f8f665a065468201bbb42dcc5cd5143259219e34 (diff) | |
| download | rabbitmq-server-git-f9e5f0632d5c5c2a586fbb5b7f29e7d040cf25bf.tar.gz | |
Maybe simpler
| -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 c087736b81..ec32e6878d 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) -> |