From 397222e3ae7140c238d0216486611ec7787f13f7 Mon Sep 17 00:00:00 2001 From: Viktor Erlingsson Date: Tue, 12 Nov 2024 17:16:50 +0100 Subject: [PATCH] lint --- spec/stream_queue_spec.cr | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spec/stream_queue_spec.cr b/spec/stream_queue_spec.cr index e7d09c839..d7f048cb9 100644 --- a/spec/stream_queue_spec.cr +++ b/spec/stream_queue_spec.cr @@ -613,7 +613,7 @@ describe LavinMQ::AMQP::StreamQueue do StreamQueueSpecHelpers.publish(s, queue_name, 1) data_dir = File.join(s.vhosts["/"].data_dir, Digest::SHA1.hexdigest queue_name) msg_store = LavinMQ::AMQP::StreamQueue::StreamQueueMessageStore.new(data_dir, nil) - one_offset_bytesize = "#{consumer_tag_prefix}#{1000}".bytesize + 1 + 8 + one_offset_bytesize = "#{consumer_tag_prefix}1000".bytesize + 1 + 8 offsets = (LavinMQ::Config.instance.segment_size / one_offset_bytesize).to_i32 + 1 bytesize = 0 offsets.times do |i|