diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-06-15 06:33:04 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-06-15 06:33:04 +0100 |
| commit | 4cbebceb0e5efd6591cd2f8fe07e6cacb31fcc6a (patch) | |
| tree | b1d5068527a6cfee96acb59573c1c72869ab1b04 | |
| parent | ccb2835c505c3f8be0ea7c7f8e2884de55b96208 (diff) | |
| download | rabbitmq-server-git-4cbebceb0e5efd6591cd2f8fe07e6cacb31fcc6a.tar.gz | |
tweak: trust our own code a bit more
| -rw-r--r-- | src/rabbit_variable_queue.erl | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index a5547f6bd8..c75a2b11bd 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1020,8 +1020,7 @@ fetch_from_q3_to_q4(State = #vqstate { {{value, IndexOnDisk, MsgStatus = #msg_status { msg = undefined, guid = Guid, is_persistent = IsPersistent }}, Q3a} -> - {{ok, Msg = #basic_message { is_persistent = IsPersistent, - guid = Guid }}, MSCState1} = + {{ok, Msg = #basic_message {}}, MSCState1} = read_from_msg_store(MSCState, IsPersistent, Guid), Q4a = queue:in(MsgStatus #msg_status { msg = Msg }, Q4), RamIndexCount1 = RamIndexCount - one_if(not IndexOnDisk), |