summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMatthias Radestock <matthias@rabbitmq.com>2013-01-13 10:22:07 +0000
committerMatthias Radestock <matthias@rabbitmq.com>2013-01-13 10:22:07 +0000
commitd2e4fff191483fd69a5fc3eee03ba0a10a15008e (patch)
treead22af42fb528a3db2f85cdd69ceb0e0a29b705f /src
parentc925948f9b22268f948a5ff0bc888e9e2a77c935 (diff)
parent5ac7b28855c59a3e10667f372198ccd90a2105b8 (diff)
downloadrabbitmq-server-git-d2e4fff191483fd69a5fc3eee03ba0a10a15008e.tar.gz
merge bug25397 into bug25395
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_variable_queue.erl4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl
index dcaaa5ed60..d3147999a5 100644
--- a/src/rabbit_variable_queue.erl
+++ b/src/rabbit_variable_queue.erl
@@ -1473,8 +1473,8 @@ next({delta, Delta, [M | Rest], State}, IndexState) ->
next({Key, Q, State}, IndexState) ->
case ?QUEUE:out(Q) of
{empty, _Q} -> next(istate(Key, State), IndexState);
- {{value, MsgStatus}, QN} -> {value, MsgStatus, {Key, QN, State},
- IndexState}
+ {{value, MsgStatus}, QN} -> Next = {Key, QN, State},
+ {value, MsgStatus, Next, IndexState}
end.
ifold(Fun, Acc, It, State = #vqstate{index_state = IndexState}) ->