Log number of messages loaded (#848)

cloudamqp · Nov 18, 2024 · 10527ee · 10527ee
1 parent 53173a5
commit 10527ee
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/lavinmq/amqp/queue/message_store.cr b/src/lavinmq/amqp/queue/message_store.cr
@@ -376,14 +376,14 @@ module LavinMQ
           mfile.pos = 4
           mfile.unmap # will be mmap on demand
           if is_long_queue
-            @log.info { "Loaded #{counter}/#{@segments.size} segments" } if (counter &+= 1) % 128 == 0
+            @log.info { "Loaded #{counter}/#{@segments.size} segments, #{@size} messages" } if (counter &+= 1) % 128 == 0
           else
-            @log.debug { "Loaded #{counter}/#{@segments.size} segments" } if (counter &+= 1) % 128 == 0
+            @log.debug { "Loaded #{counter}/#{@segments.size} segments, #{@size} messages" } if (counter &+= 1) % 128 == 0
           end
           Fiber.yield
           @segment_msg_count[seg] = count
         end
-        @log.info { "Loaded #{counter} segments" }
+        @log.info { "Loaded #{counter} segments, #{@size} messages" }
       end
 
       private def update_stats_per_msg(seg, ts, bytesize)