diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2011-06-26 10:06:05 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2011-06-26 10:06:05 +0100 |
| commit | 03ac4d0eb20ab6cf4db01c5a518a37f42ced6ae4 (patch) | |
| tree | a048126f79c03fe00462ed0005060880070fcb2b | |
| parent | 1ee9fc064fb2671ad20eee8d0c090105b497dbab (diff) | |
| download | rabbitmq-server-git-03ac4d0eb20ab6cf4db01c5a518a37f42ced6ae4.tar.gz | |
meh
| -rw-r--r-- | src/rabbit_variable_queue.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index e9d302f1ad..c6d99deb6a 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1063,8 +1063,9 @@ in_r(MsgStatus = #msg_status { msg = undefined, index_on_disk = IndexOnDisk }, true -> State #vqstate { q3 = bpqueue:in_r(IndexOnDisk, MsgStatus, Q3), ram_index_count = RamIndexCount + one_if(not IndexOnDisk) }; - false -> {MsgStatus1, State1} = read_msg(MsgStatus, State), - State1 #vqstate { q4 = queue:in_r(MsgStatus1, Q4) } + false -> {MsgStatus1, State1 = #vqstate { q4 = Q4a }} = + read_msg(MsgStatus, State), + State1 #vqstate { q4 = queue:in_r(MsgStatus1, Q4a) } end; in_r(MsgStatus, State = #vqstate { q4 = Q4 }) -> State #vqstate { q4 = queue:in_r(MsgStatus, Q4) }. |