diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-08-17 13:08:46 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-08-17 13:08:46 +0100 |
| commit | 70fcd8fc6acc17a51f668821a3581b972dcd7d79 (patch) | |
| tree | 7768c285dfa527761957e16ab96ef8104bae9180 | |
| parent | 1a7940bbc28618ed34ed97eda70d6573631dd98d (diff) | |
| download | rabbitmq-server-70fcd8fc6acc17a51f668821a3581b972dcd7d79.tar.gz | |
No need to do the append
| -rw-r--r-- | src/rabbit_limiter.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_limiter.erl b/src/rabbit_limiter.erl index 8f9ab032..d43ec1fc 100644 --- a/src/rabbit_limiter.erl +++ b/src/rabbit_limiter.erl @@ -227,7 +227,8 @@ notify_queues(State = #lim{ch_pid = ChPid, queues = Queues}) -> %% thus ensuring that each queue has an equal chance of %% being notified first. {L1, L2} = lists:split(random:uniform(L), QList), - [ok = rabbit_amqqueue:unblock(Q, ChPid) || Q <- L2 ++ L1], + [[ok = rabbit_amqqueue:unblock(Q, ChPid) || Q <- L3] + || L3 <- [L2, L1]], ok end, State#lim{queues = NewQueues}. |