summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@lshift.net>2009-03-13 08:43:57 +0000
committerMatthias Radestock <matthias@lshift.net>2009-03-13 08:43:57 +0000
commitde5f50f4d73f6768f810d8aaa0f354ca785c89de (patch)
treea8e845bb56b6c55988c7410074f263919053c176 /src
parentb83f85e5f268e641d5e63d768267d9b86b949d83 (diff)
downloadrabbitmq-server-git-de5f50f4d73f6768f810d8aaa0f354ca785c89de.tar.gz
fix bug
Diffstat (limited to 'src')
-rw-r--r--src/priority_queue.erl2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/priority_queue.erl b/src/priority_queue.erl
index e29d4a7bb5..5c10259b1a 100644
--- a/src/priority_queue.erl
+++ b/src/priority_queue.erl
@@ -78,7 +78,7 @@ len({pqueue, Queues}) ->
to_list({queue, In, Out}) when is_list(In), is_list(Out) ->
[{0, V} || V <- Out ++ lists:reverse(In, [])];
to_list({pqueue, Queues}) ->
- [{P, V} || {P, Q} <- Queues, V <- queue:to_list(Q)].
+ [{-P, V} || {P, Q} <- Queues, V <- queue:to_list(Q)].
in(Item, Q) ->
in(Item, 0, Q).