Contents

# based on http://bit.ly/VGdfVI

module Delayed
  module Plugins
    class Rollbar < Plugin
      module ReportErrors
        def error(job, error)
          # send the job object as the 'request data'
          ::Rollbar.report_exception(error, job)
          super if defined?(super)
        end
      end

      callbacks do |lifecycle|
        lifecycle.before(:invoke_job) do |job|
          payload = job.payload_object
          payload = payload.object if payload.is_a? Delayed::PerformableMethod
          payload.extend ReportErrors
        end
      end
    end
  end
end

Delayed::Worker.plugins << Delayed::Plugins::Rollbar

Version data entries

44 entries across 44 versions & 1 rubygems

Version	Path
rollbar-0.8.3	lib/rollbar/delayed_job.rb
rollbar-0.8.2	lib/rollbar/delayed_job.rb
rollbar-0.8.1	lib/rollbar/delayed_job.rb
rollbar-0.8.0	lib/rollbar/delayed_job.rb