summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatthew Sackman <matthew@lshift.net>2009-08-26 14:03:03 +0100
committerMatthew Sackman <matthew@lshift.net>2009-08-26 14:03:03 +0100
commit80643baa902f4b01fdae3b8ffc0096568cd86be1 (patch)
tree484690f233da8a58d7cb35063a09072adb19fbc0
parent1bbb4a1681059830077a7a09a373078f2d5da70b (diff)
downloadrabbitmq-server-git-80643baa902f4b01fdae3b8ffc0096568cd86be1.tar.gz
cosmetic
-rw-r--r--src/rabbit_mixed_queue.erl2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_mixed_queue.erl b/src/rabbit_mixed_queue.erl
index af4cd834e9..9b86522f1c 100644
--- a/src/rabbit_mixed_queue.erl
+++ b/src/rabbit_mixed_queue.erl
@@ -367,11 +367,11 @@ fetch(State = #mqstate { msg_buf = MsgBuf, queue = Q,
{{Msg, IsDelivered, AckTag1, Rem},
State1 #mqstate { msg_buf = MsgBuf2 }};
_ ->
+ %% use State, not State1 as we've not dec'd length
fetch(case rabbit_queue_prefetcher:drain(Prefetcher) of
empty -> State #mqstate { prefetcher = undefined };
{Fetched, Len, Status} ->
MsgBuf2 = dec_queue_length(MsgBuf, Len),
- %% use State, not State1 as we've not dec'd length
State #mqstate
{ msg_buf = queue:join(Fetched, MsgBuf2),
prefetcher = case Status of