diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 6745621964..dfcfc8b3db 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -1357,7 +1357,8 @@ in_r(MsgStatus = #msg_status { seq_id = SeqId }, State = #vqstate { mode = lazy, q3 = Q3, delta = Delta}) -> case ?QUEUE:is_empty(Q3) of true -> - State1 = maybe_write_to_disk(true, true, MsgStatus, State), + {_MsgStatus1, State1} = + maybe_write_to_disk(true, true, MsgStatus, State), State2 = stats(ready0, {MsgStatus, none}, State1), Delta1 = expand_delta(SeqId, Delta), State2 #vqstate{ delta = Delta1 }; |