diff options
| author | Matthew Sackman <matthew@lshift.net> | 2009-08-26 14:03:03 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@lshift.net> | 2009-08-26 14:03:03 +0100 |
| commit | 80643baa902f4b01fdae3b8ffc0096568cd86be1 (patch) | |
| tree | 484690f233da8a58d7cb35063a09072adb19fbc0 | |
| parent | 1bbb4a1681059830077a7a09a373078f2d5da70b (diff) | |
| download | rabbitmq-server-git-80643baa902f4b01fdae3b8ffc0096568cd86be1.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_mixed_queue.erl | 2 |
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 |
