Class: RailsBand::ActiveJob::LogSubscriber

Inherits:
ActiveSupport::LogSubscriber
  • Object
show all
Defined in:
lib/rails_band/active_job/log_subscriber.rb

Overview

The custom LogSubscriber for ActiveJob.

Instance Method Summary collapse

Instance Method Details

#discard(event) ⇒ Object 



47
48
49
 
# File 'lib/rails_band/active_job/log_subscriber.rb', line 47

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

#enqueue(event) ⇒ Object 



27
28
29
 
# File 'lib/rails_band/active_job/log_subscriber.rb', line 27

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

#enqueue_all(event) ⇒ Object 



51
52
53
 
# File 'lib/rails_band/active_job/log_subscriber.rb', line 51

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

#enqueue_at(event) ⇒ Object 



23
24
25
 
# File 'lib/rails_band/active_job/log_subscriber.rb', line 23

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

#enqueue_retry(event) ⇒ Object 



31
32
33
 
# File 'lib/rails_band/active_job/log_subscriber.rb', line 31

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

#interrupt(event) ⇒ Object 



55
56
57
 
# File 'lib/rails_band/active_job/log_subscriber.rb', line 55

def interrupt(event)
  consumer_of(__method__)&.call(Event::Interrupt.new(event))
end

#perform(event) ⇒ Object 



39
40
41
 
# File 'lib/rails_band/active_job/log_subscriber.rb', line 39

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

#perform_start(event) ⇒ Object 



35
36
37
 
# File 'lib/rails_band/active_job/log_subscriber.rb', line 35

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

#resume(event) ⇒ Object 



59
60
61
 
# File 'lib/rails_band/active_job/log_subscriber.rb', line 59

def resume(event)
  consumer_of(__method__)&.call(Event::Resume.new(event))
end

#retry_stopped(event) ⇒ Object 



43
44
45
 
# File 'lib/rails_band/active_job/log_subscriber.rb', line 43

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

#step(event) ⇒ Object 



63
64
65
 
# File 'lib/rails_band/active_job/log_subscriber.rb', line 63

def step(event)
  consumer_of(__method__)&.call(Event::Step.new(event))
end

#step_skipped(event) ⇒ Object 



67
68
69
 
# File 'lib/rails_band/active_job/log_subscriber.rb', line 67

def step_skipped(event)
  consumer_of(__method__)&.call(Event::StepSkipped.new(event))
end

#step_started(event) ⇒ Object 



71
72
73
 
# File 'lib/rails_band/active_job/log_subscriber.rb', line 71

def step_started(event)
  consumer_of(__method__)&.call(Event::StepStarted.new(event))
end