only sleep if there were no events processed, update defaults

Author: effron

lib/journaled.rb

@@ -31,8 +31,8 @@ module Journaled
   mattr_writer(:transactional_batching_enabled) { true }
 
   # Worker configuration (for Outbox-style event processing)
-  mattr_accessor(:worker_batch_size) { 500 }
-  mattr_accessor(:worker_poll_interval) { 5 } # seconds
+  mattr_accessor(:worker_batch_size) { 1000 }
+  mattr_accessor(:worker_poll_interval) { 1 } # seconds
 
   def self.transactional_batching_enabled?
     Thread.current[:journaled_transactional_batching_enabled] || @@transactional_batching_enabled

lib/journaled/outbox/worker.rb

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