use old_consumer_offsets.path

cloudamqp · Jun 19, 2024 · ec8c733 · ec8c733
1 parent 6c66ad8
commit ec8c733
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/lavinmq/queue/stream_queue_message_store.cr b/src/lavinmq/queue/stream_queue_message_store.cr
@@ -173,9 +173,9 @@ module LavinMQ
 
       def replace_offsets_file(&)
         old_consumer_offsets = @consumer_offsets
-        @consumer_offsets = MFile.new("#{@consumer_offsets.path}.tmp", 32 * 1024)
+        @consumer_offsets = MFile.new("#{old_consumer_offsets.path}.tmp", 32 * 1024)
         yield # fill the new file with correct data in this block
-        @consumer_offsets.rename(@consumer_offsets.path.sub(".tmp",""))
+        @consumer_offsets.rename(old_consumer_offsets.path)
         old_consumer_offsets.close(truncate_to_size: false)
       end