Contents

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

module Delayed
  module Plugins
    class Rollbar < Plugin
      callbacks do |lifecycle|
        lifecycle.around(:invoke_job) do |job, *args, &block|
          begin
            block.call(job, *args)
          rescue Exception => e
            if job.attempts >= ::Rollbar.configuration.dj_threshold
              data = ::Rollbar.configuration.report_dj_data ? job : nil
              ::Rollbar.report_exception(e, data)
            end
            raise e
          end
        end
      end
    end
  end
end

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

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
rollbar-0.12.20	lib/rollbar/delayed_job.rb
rollbar-0.12.19	lib/rollbar/delayed_job.rb
rollbar-0.12.18	lib/rollbar/delayed_job.rb
rollbar-0.12.17	lib/rollbar/delayed_job.rb
rollbar-0.12.16	lib/rollbar/delayed_job.rb
rollbar-0.12.15	lib/rollbar/delayed_job.rb
rollbar-0.12.14	lib/rollbar/delayed_job.rb