Class: RailsTransactionalOutbox::OutboxEntriesProcessors::BaseProcessor

Inherits:

Object

• Object
• RailsTransactionalOutbox::OutboxEntriesProcessors::BaseProcessor

Defined in:

lib/rails_transactional_outbox/outbox_entries_processors/base_processor.rb

Direct Known Subclasses

NonOrderedProcessor, OrderedByCausalityKeyProcessor

Instance Method Summary

• #call(&block) ⇒ Object
• #initialize(config: RailsTransactionalOutbox.configuration) ⇒ BaseProcessor constructor

  A new instance of BaseProcessor.

Constructor Details

#initialize(config: RailsTransactionalOutbox.configuration) ⇒ BaseProcessor

Returns a new instance of BaseProcessor.

# File 'lib/rails_transactional_outbox/outbox_entries_processors/base_processor.rb', line 9

def initialize(config: RailsTransactionalOutbox.configuration)
  @config = config
end

Instance Method Details

#call(&block) ⇒ Object

# File 'lib/rails_transactional_outbox/outbox_entries_processors/base_processor.rb', line 13

def call(&block)
  return [] unless outbox_model.any_records_to_process?

  execute(&block)
end