Contents

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

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
outboxable-0.1.2	lib/outboxable/polling_publisher_worker.rb
outboxable-0.1.1	lib/outboxable/polling_publisher_worker.rb
outboxable-0.1.0	lib/outboxable/polling_publisher_worker.rb