Class: Pigeon::ActiveJobIntegration::ProcessorJob

Inherits:

ActiveJob::Base

Object
ActiveJob::Base
Pigeon::ActiveJobIntegration::ProcessorJob

show all

Defined in:: lib/pigeon/active_job_integration.rb

Overview

Job for processing pending outbox messages

Instance Method Summary collapse

#perform(batch_size = 100) ⇒ Hash

Process pending outbox messages.

Instance 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



15
16
17

# File 'lib/pigeon/active_job_integration.rb', line 15

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