From de294187e4a2b0d4b99be44c9c253467d52cb32a 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 2a12e04247..ae844edbf4 100644 --- a/spec/stream_queue_spec.cr +++ b/spec/stream_queue_spec.cr @@ -489,7 +489,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|