From d52b6f5bd746e9704b39df9ab17eea3a8070e30a Mon Sep 17 00:00:00 2001
From: Viktor Erlingsson <viktor@84codes.com>
Date: Wed, 19 Jun 2024 15:17:18 +0200
Subject: [PATCH] start reading at pos=4 after IndexError in offset_at

---
 src/lavinmq/queue/stream_queue_message_store.cr | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/lavinmq/queue/stream_queue_message_store.cr b/src/lavinmq/queue/stream_queue_message_store.cr
index 9b106c4e4..0255baf1e 100644
--- a/src/lavinmq/queue/stream_queue_message_store.cr
+++ b/src/lavinmq/queue/stream_queue_message_store.cr
@@ -68,7 +68,7 @@ module LavinMQ
         offset = offset_from_headers(msg.properties.headers)
         {offset, seg, pos}
       rescue ex : IndexError # first segment can be empty if message size >= segment size
-        return offset_at(seg + 1, pos, true) unless retried
+        return offset_at(seg + 1, 4_u32, true) unless retried
         raise ex
       end