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 | c7d06d2bf333f37ebf649ea354c87dc71bd62c55 (patch) | |
| tree | 7768c285dfa527761957e16ab96ef8104bae9180 | |
| parent | a79e0dab1ee45f9a7877a7fcd69756e15683542a (diff) | |
| download | rabbitmq-server-git-c7d06d2bf333f37ebf649ea354c87dc71bd62c55.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 8f9ab0321a..d43ec1fcbb 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}. |