Class: Pigeon::ActiveJobIntegration::CleanupJob

Inherits:
ActiveJob::Base
  • Object
show all
Defined in:
lib/pigeon/active_job_integration.rb

Overview

Job for cleaning up processed outbox messages

Instance Method Summary collapse

Instance Method Details

#perform(older_than = 7) ⇒ Integer

Clean up processed outbox messages

Parameters:

  • older_than (Integer) (defaults to: 7)

    Age threshold for cleanup in days

Returns:

  • (Integer)

    Number of records cleaned up



27
28
29
# File 'lib/pigeon/active_job_integration.rb', line 27

def perform(older_than = 7)
  Pigeon.processor.cleanup_processed(older_than: older_than)
end