From ec8c7330e2c943f599e33b9457b0b66041fe69fa Mon Sep 17 00:00:00 2001 From: Viktor Erlingsson Date: Wed, 19 Jun 2024 14:42:41 +0200 Subject: [PATCH] use old_consumer_offsets.path --- src/lavinmq/queue/stream_queue_message_store.cr | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/lavinmq/queue/stream_queue_message_store.cr b/src/lavinmq/queue/stream_queue_message_store.cr index 336abc4528..9b106c4e4b 100644 --- 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