Contents

# frozen_string_literal: true

class RailsTransactionalOutbox
  class OutboxEntriesProcessors
    class NonOrderedProcessor < RailsTransactionalOutbox::OutboxEntriesProcessors::BaseProcessor
      private

      delegate :transaction_provider, to: :config
      delegate :transaction, to: :transaction_provider

      def execute(&block)
        transaction do
          outbox_model.fetch_processable(outbox_batch_size).to_a.tap do |records_to_process|
            process_records(records_to_process, &block)
          end
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
rails-transactional-outbox-0.4.0	lib/rails_transactional_outbox/outbox_entries_processors/non_ordered_processor.rb
rails-transactional-outbox-0.3.1	lib/rails_transactional_outbox/outbox_entries_processors/non_ordered_processor.rb
rails-transactional-outbox-0.3.0	lib/rails_transactional_outbox/outbox_entries_processors/non_ordered_processor.rb
rails-transactional-outbox-0.2.1	lib/rails_transactional_outbox/outbox_entries_processors/non_ordered_processor.rb
rails-transactional-outbox-0.2.0	lib/rails_transactional_outbox/outbox_entries_processors/non_ordered_processor.rb