Adds workers

lib/outboxable/polling_publisher_worker.rb

@@ -0,0 +1,14 @@
+module Outboxable
+  class PollingPublisherWorker
+    include Sidekiq::Job
+    sidekiq_options queue: 'critical'
+
+    def perform
+      Outbox.pending.find_in_batches(batch_size: 100).each do |batch|
+        batch.each do |outbox|
+          Outboxable::Worker.perform_async(outbox.id)
+        end
+      end
+    end
+  end
+end

lib/outboxable/worker.rb

@@ -0,0 +1,9 @@
+module Outboxable
+  class Worker
+    include Sidekiq::Job
+
+    def perform(outbox_id)
+      Outboxable::PublishingManager.publish(resource: Outbox.find(outbox_id))
+    end
+  end
+end