Class: Pigeon::HanamiIntegration::ProcessorJob

Inherits:
Object
  • Object
show all
Defined in:
lib/pigeon/hanami_integration.rb

Overview

Background job for processing outbox messages

Class Method Summary collapse

Class Method Details

.perform(batch_size = 100) ⇒ Hash

Process pending outbox messages

Parameters:

  • batch_size (Integer) (defaults to: 100) —

    Number of messages to process in one batch

Returns:

  • (Hash) —

    Processing statistics



61
62
63
 
# File 'lib/pigeon/hanami_integration.rb', line 61

def self.perform(batch_size = 100)
  Pigeon.processor.process_pending(batch_size: batch_size)
end