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