also remove timestamp index when deleting segment

Co-authored-by: Carl Hörberg <carl@84codes.com>
cloudamqp · Nov 13, 2024 · 7bbbae3 · 7bbbae3
1 parent bffba44
commit 7bbbae3
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/lavinmq/amqp/queue/stream_queue_message_store.cr b/src/lavinmq/amqp/queue/stream_queue_message_store.cr
@@ -201,6 +201,7 @@ module LavinMQ::AMQP
           @size -= msg_count if msg_count
           @segment_last_ts.delete(seg_id)
           @offset_index.delete(seg_id)
+          @timestamp_index.delete(seg_id)
           @bytesize -= mfile.size - 4
           mfile.delete.close
           @replicator.try &.delete_file(mfile.path)