class RailsBand::ActiveJob::LogSubscriber

The custom LogSubscriber for ActiveJob.

Public Instance Methods

discard(event) click to toggle source
# File lib/rails_band/active_job/log_subscriber.rb, line 41
def discard(event)
  consumer_of(__method__)&.call(Event::Discard.new(event))
end
enqueue(event) click to toggle source
# File lib/rails_band/active_job/log_subscriber.rb, line 21
def enqueue(event)
  consumer_of(__method__)&.call(Event::Enqueue.new(event))
end
enqueue_at(event) click to toggle source
# File lib/rails_band/active_job/log_subscriber.rb, line 17
def enqueue_at(event)
  consumer_of(__method__)&.call(Event::EnqueueAt.new(event))
end
enqueue_retry(event) click to toggle source
# File lib/rails_band/active_job/log_subscriber.rb, line 25
def enqueue_retry(event)
  consumer_of(__method__)&.call(Event::EnqueueRetry.new(event))
end
perform(event) click to toggle source
# File lib/rails_band/active_job/log_subscriber.rb, line 33
def perform(event)
  consumer_of(__method__)&.call(Event::Perform.new(event))
end
perform_start(event) click to toggle source
# File lib/rails_band/active_job/log_subscriber.rb, line 29
def perform_start(event)
  consumer_of(__method__)&.call(Event::PerformStart.new(event))
end
retry_stopped(event) click to toggle source
# File lib/rails_band/active_job/log_subscriber.rb, line 37
def retry_stopped(event)
  consumer_of(__method__)&.call(Event::RetryStopped.new(event))
end

Private Instance Methods

consumer_of(sub_event) click to toggle source
# File lib/rails_band/active_job/log_subscriber.rb, line 47
def consumer_of(sub_event)
  consumers[:"#{sub_event}.active_job"] || consumers[:active_job] || consumers[:default]
end