From 7e94d7092336ecfae810a7e645407d9211acaa8b Mon Sep 17 00:00:00 2001 From: Viktor Erlingsson Date: Mon, 27 Jan 2025 15:03:03 +0100 Subject: [PATCH] fix specs --- spec/stream_queue_spec.cr | 2 ++ 1 file changed, 2 insertions(+) diff --git a/spec/stream_queue_spec.cr b/spec/stream_queue_spec.cr index 361d8b8d96..efa3c32320 100644 --- a/spec/stream_queue_spec.cr +++ b/spec/stream_queue_spec.cr @@ -360,6 +360,8 @@ describe LavinMQ::AMQP::StreamQueue do msg.body_io.to_s.should eq "msg with filter 2" end end + end + end describe "Automatic consumer offset tracking" do it "resumes from last offset on reconnect" do queue_name = Random::Secure.hex