Class: Pigeon::ActiveJobIntegration::ProcessorJob

Inherits:

ActiveJob::Base

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

Defined in:

lib/pigeon/active_job_integration.rb

Overview

Job for processing pending outbox messages

Instance Method Summary

• #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

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

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