Class: Pigeon::HanamiIntegration::ProcessorJob

Inherits:

Object

Object
Pigeon::HanamiIntegration::ProcessorJob

show all

Defined in:: lib/pigeon/hanami_integration.rb

Overview

Background job for processing outbox messages

Class Method Summary collapse

.perform(batch_size = 100) ⇒ Hash

Process pending outbox messages.

Class Method Details

.perform(batch_size = 100) ⇒ `Hash`

Process pending outbox messages



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