summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@lshift.net>2010-04-20 18:10:21 +0100
committerMatthew Sackman <matthew@lshift.net>2010-04-20 18:10:21 +0100
commit29071f33bb3dffc3454f175420f42f80668ea078 (patch)
tree8f722ba13f6c755c9bea9fd93e8ec459e46e10f1
parent59d4fa4e0bb24657f569d4343b3e853c007be18b (diff)
downloadrabbitmq-server-29071f33bb3dffc3454f175420f42f80668ea078.tar.gz
Correct list comprehension
-rw-r--r--src/rabbit_persister.erl2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_persister.erl b/src/rabbit_persister.erl
index aee8cfd4..dd87689a 100644
--- a/src/rabbit_persister.erl
+++ b/src/rabbit_persister.erl
@@ -423,7 +423,7 @@ requeue_messages(Snapshot = #psnapshot{messages = Messages,
fun ({QName, Requeues}) ->
requeue(QName, Requeues, Messages)
end, dict:to_list(Work))),
- NewMessages = [{K, M} || {{_Q, K}, M, _D} <- L],
+ NewMessages = [{K, M} || {{_S, _Q, K}, M, _D} <- L],
NewQueues = [{{Q, K}, D, S} || {{S, Q, K}, _M, D} <- L],
ets:delete_all_objects(Messages),
ets:delete_all_objects(Queues),