diff options
| -rw-r--r-- | src/rabbit_amqqueue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 1f11a77a..b80b4dbc 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -527,9 +527,9 @@ force_event_refresh(Ref) -> force_event_refresh(list(), Ref). force_event_refresh(Qs, Ref) -> {_, Bad} = gen_server2:mcall( [{Q#amqqueue.pid, {force_event_refresh, Ref}} || Q <- Qs]), - FailedPids = [Pid || {Pid, _Reason} <- Bad], + FailedPids = gb_sets:from_list([Pid || {Pid, _Reason} <- Bad]), case [Name || #amqqueue{name = Name, pid = Pid} <- Qs, - lists:member(Pid, FailedPids)] of + gb_sets:is_element(Pid, FailedPids)] of [] -> ok; Failed -> timer:sleep(?FAILOVER_WAIT_MILLIS), force_event_refresh(lookup(Failed), Ref) |