class RailsBand::ActiveJob::LogSubscriber

The custom LogSubscriber for ActiveJob.

def consumer_of(sub_event) 

def consumer_of(sub_event)
  consumers[:"#{sub_event}.active_job"] || consumers[:active_job] || consumers[:default]
end

def discard(event) 

def discard(event)
  consumer_of(__method__)&.call(Event::Discard.new(event))
end

def enqueue(event) 

def enqueue(event)
  consumer_of(__method__)&.call(Event::Enqueue.new(event))
end

def enqueue_all(event) 

def enqueue_all(event)
  consumer_of(__method__)&.call(Event::EnqueueAll.new(event))
end

def enqueue_at(event) 

def enqueue_at(event)
  consumer_of(__method__)&.call(Event::EnqueueAt.new(event))
end

def enqueue_retry(event) 

def enqueue_retry(event)
  consumer_of(__method__)&.call(Event::EnqueueRetry.new(event))
end

def perform(event) 

def perform(event)
  consumer_of(__method__)&.call(Event::Perform.new(event))
end

def perform_start(event) 

def perform_start(event)
  consumer_of(__method__)&.call(Event::PerformStart.new(event))
end

def retry_stopped(event) 

def retry_stopped(event)
  consumer_of(__method__)&.call(Event::RetryStopped.new(event))
end