Module: Cosmo::ActiveJobAdapter::Options

Defined in:
lib/cosmo/active_job/options.rb

Overview

Adds cosmo_options to ActiveJob classes.

class MyJob < ApplicationJob
  cosmo_options retry: 5, dead: false

  def perform(user_id)
    # ...
  end
end

Options mirror those accepted by Cosmo::Job:

retry:  [Integer]  Number of retries before giving up (default: 3)
dead:   [Boolean]  Move to DLQ when retries exhausted? (default: true)
stream: [Symbol]   Override the NATS stream (default: derived from queue_name)

Defined Under Namespace

Modules: ClassMethods

Constant Summary collapse

VALID_OPTIONS = 
%i[retry dead stream].freeze

Class Method Summary collapse

Class Method Details

.included(base) ⇒ Object 



22
23
24
 
# File 'lib/cosmo/active_job/options.rb', line 22

def self.included(base)
  base.extend(ClassMethods)
end