Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- module Delayed
- module Plugins
- class Airbrake < Plugin
- module Notify
- def error(job, error)
- ::Airbrake.notify_or_ignore(error)
- 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 Notify
- end
- end
- end
- end
- end
- Delayed::Worker.plugins << Delayed::Plugins::Airbrake
Add Comment
Please, Sign In to add comment