shorten default sleep, always sleep between batches to prevent excessive database polling

Author: effron

lib/journaled.rb

@@ -34,7 +34,7 @@ module Journaled
 
   # Worker configuration (for Outbox-style event processing)
   mattr_accessor(:worker_batch_size) { 500 }
-  mattr_accessor(:worker_poll_interval) { 1 } # seconds
+  mattr_accessor(:worker_poll_interval) { 0.5 } # seconds
   mattr_accessor(:outbox_processing_mode) { :batch } # :batch or :guaranteed_order
 
   def self.transactional_batching_enabled?

lib/journaled/outbox/worker.rb

@@ -60,9 +60,8 @@ def run_loop
             break
           end
 
-          events_processed = 0
           begin
-            events_processed = process_batch
+            process_batch
             emit_metrics_if_needed
           rescue StandardError => e
             Rails.logger.error("Worker error: #{e.class} - #{e.message}")
@@ -71,20 +70,13 @@ def run_loop
 
           break if shutdown_requested
 
-          # Only sleep if no events were processed to prevent excessive polling on empty table
-          sleep(Journaled.worker_poll_interval) if events_processed.zero?
+          sleep(Journaled.worker_poll_interval)
         end
       end
 
       def process_batch
         stats = processor.process_batch
 
-        instrument_batch_results(stats)
-
-        stats[:succeeded] + stats[:failed_permanently]
-      end
-
-      def instrument_batch_results(stats)
         metric_emitter.emit_batch_metrics(stats)
       end