call stop directly

fast-programmer · Aug 12, 2024 · 4a00662 · 4a00662
1 parent 8152d8b
commit 4a00662
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/outboxer/publisher.rb b/lib/outboxer/publisher.rb
@@ -77,7 +77,7 @@ def create_worker_thread(queue:, logger:, &block)
               "in #{(Time.now.utc - dequeued_at).round(3)}s"
             exception.backtrace.each { |frame| logger.error frame }
 
-            @stopped = true
+            stop
 
             break
           end