From 189b66bdc1517fea8adcf1ef380b2ba83b19b92a Mon Sep 17 00:00:00 2001 From: Viktor Erlingsson Date: Mon, 4 Nov 2024 16:38:34 +0100 Subject: [PATCH] format --- src/lavinmq/amqp/queue/stream_queue_message_store.cr | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/lavinmq/amqp/queue/stream_queue_message_store.cr b/src/lavinmq/amqp/queue/stream_queue_message_store.cr index f978f43f07..ad6bc149f9 100644 --- a/src/lavinmq/amqp/queue/stream_queue_message_store.cr +++ b/src/lavinmq/amqp/queue/stream_queue_message_store.cr @@ -9,8 +9,8 @@ module LavinMQ::AMQP property max_age : Time::Span | Time::MonthSpan | Nil getter last_offset : Int64 @segment_last_ts = Hash(UInt32, Int64).new(0i64) # used for max-age - @offset_index : Hash(UInt32, Int64) # segment_id => offset of first msg - @offset_index_ts : Hash(UInt32, Int64) # segment_id => ts of first msg + @offset_index : Hash(UInt32, Int64) # segment_id => offset of first msg + @offset_index_ts : Hash(UInt32, Int64) # segment_id => ts of first msg def initialize(*args, **kwargs) super