diff options
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 58e3f5a377..42a01577b0 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -246,7 +246,7 @@ publish_delivered(Msg = #basic_message { guid = MsgId, in_counter = InCount + 1 }, MsgStatus = #msg_status { msg = Msg, msg_id = MsgId, seq_id = SeqId, is_persistent = IsPersistent, - is_delivered = false, msg_on_disk = false, index_on_disk = false }, + is_delivered = true, msg_on_disk = false, index_on_disk = false }, MsgStatus1 = maybe_write_msg_to_disk(false, MsgStatus), case MsgStatus1 #msg_status.msg_on_disk of true -> |