Class: Hickory::LogSubscribers::ActiveJob

Inherits:
ActiveSupport::LogSubscriber
  • Object
show all
Defined in:
lib/hickory/log_subscribers/active_job.rb

Instance Method Summary collapse

Instance Method Details

#enqueue(event) ⇒ Object 



4
5
6
 
# File 'lib/hickory/log_subscribers/active_job.rb', line 4

def enqueue(event)
  logger.info('job-enqueued', job_metadata(event))
end

#enqueue_retry(event) ⇒ Object 



8
9
10
11
12
13
14
15
16
 
# File 'lib/hickory/log_subscribers/active_job.rb', line 8

def enqueue_retry(event)
  metadata = job_metadata(event)
  metadata.merge!({
    error: event.payload[:error],
    wait: event.payload[:wait]
  })

  logger.info('job-retry-enqueued', metadata)
end

#perform(event) ⇒ Object 



22
23
24
 
# File 'lib/hickory/log_subscribers/active_job.rb', line 22

def perform(event)
  logger.info('job-perform', job_metadata(event))
end

#perform_start(event) ⇒ Object 



18
19
20
 
# File 'lib/hickory/log_subscribers/active_job.rb', line 18

def perform_start(event)
  logger.info('job-perform-start', job_metadata(event))
end

#retry_discard(event) ⇒ Object 



35
36
37
38
39
40
41
42
 
# File 'lib/hickory/log_subscribers/active_job.rb', line 35

def retry_discard(event)
  metadata = job_metadata(event)
  metadata.merge!({
    error: event.payload[:error]
  })

  logger.info('job-discard', metadata)
end

#retry_stopped(event) ⇒ Object 



26
27
28
29
30
31
32
33
 
# File 'lib/hickory/log_subscribers/active_job.rb', line 26

def retry_stopped(event)
  metadata = job_metadata(event)
  metadata.merge!({
    error: event.payload[:error]
  })

  logger.info('job-retry-stopped', metadata)
end