Module: Rollbar::Delayed

Defined in:
lib/rollbar/plugins/delayed_job/plugin.rb,
lib/rollbar/plugins/delayed_job/job_data.rb

Defined Under Namespace

Classes: JobData, RollbarPlugin

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.wrapped ⇒ Object

Returns the value of attribute wrapped.



7
8
9
 
# File 'lib/rollbar/plugins/delayed_job/plugin.rb', line 7

def wrapped
  @wrapped
end

Class Method Details

.build_job_data(job) ⇒ Object 



56
57
58
59
60
 
# File 'lib/rollbar/plugins/delayed_job/plugin.rb', line 56

def self.build_job_data(job)
  return nil unless ::Rollbar.configuration.report_dj_data

  JobData.new(job).to_hash
end

.invoke_job_callback ⇒ Object 



32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/rollbar/plugins/delayed_job/plugin.rb', line 32

def self.invoke_job_callback
  proc do |job, *args, &block|
    begin
      block.call(job, *args)
    rescue => e
      report(e, job)

      raise e
    end
  end
end

.report(e, job) ⇒ Object 



44
45
46
47
48
49
50
 
# File 'lib/rollbar/plugins/delayed_job/plugin.rb', line 44

def self.report(e, job)
  return if skip_report?(job)

  data = build_job_data(job)

  ::Rollbar.scope(:request => data).error(e, :use_exception_level_filters => true)
end

.skip_report?(job) ⇒ Boolean

Returns:

  • (Boolean) 


52
53
54
 
# File 'lib/rollbar/plugins/delayed_job/plugin.rb', line 52

def self.skip_report?(job)
  job.attempts < ::Rollbar.configuration.dj_threshold
end

.wrap_worker ⇒ Object 



18
19
20
21
22
23
24
 
# File 'lib/rollbar/plugins/delayed_job/plugin.rb', line 18

def self.wrap_worker
  return if wrapped

  ::Delayed::Worker.plugins << RollbarPlugin

  self.wrapped = true
end

.wrap_worker! ⇒ Object 



26
27
28
29
30
 
# File 'lib/rollbar/plugins/delayed_job/plugin.rb', line 26

def self.wrap_worker!
  self.wrapped = false

  wrap_worker
end