Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
viktorerlingsson committed Nov 4, 2024
1 parent eb8bcb4 commit 189b66b
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/lavinmq/amqp/queue/stream_queue_message_store.cr
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit 189b66b

Please sign in to comment.