aboutsummaryrefslogtreecommitdiffstats
path: root/activejob/lib
diff options
context:
space:
mode:
authorAidan Haran <aidanharan@Aidans-MacBook-Pro.local>2017-09-16 19:59:32 +0100
committerAidan Haran <aidanharan@Aidans-MacBook-Pro.local>2017-09-16 19:59:32 +0100
commit3291fa3630c456450f8c6a9b771f77c293d036cd (patch)
treed8b3a6311df9b233955209d6c33f0fa07c2c7285 /activejob/lib
parent34956f7422798f27f8926544d58771042f6f1c3a (diff)
downloadrails-3291fa3630c456450f8c6a9b771f77c293d036cd.tar.gz
rails-3291fa3630c456450f8c6a9b771f77c293d036cd.tar.bz2
rails-3291fa3630c456450f8c6a9b771f77c293d036cd.zip
Allow for custom handling of exceptions that are discarded
Diffstat (limited to 'activejob/lib')
-rw-r--r--activejob/lib/active_job/exceptions.rb12
1 files changed, 11 insertions, 1 deletions
diff --git a/activejob/lib/active_job/exceptions.rb b/activejob/lib/active_job/exceptions.rb
index dfc74deb1a..21d823eef9 100644
--- a/activejob/lib/active_job/exceptions.rb
+++ b/activejob/lib/active_job/exceptions.rb
@@ -61,18 +61,28 @@ module ActiveJob
# Discard the job with no attempts to retry, if the exception is raised. This is useful when the subject of the job,
# like an Active Record, is no longer available, and the job is thus no longer relevant.
#
+ # You can also pass a block that'll be invoked. This block is yielded with the job instance as the first and the error instance as the second parameter.
+ #
# ==== Example
#
# class SearchIndexingJob < ActiveJob::Base
# discard_on ActiveJob::DeserializationError
+ # discard_on(CustomAppException) do |job, exception|
+ # ExceptionNotifier.caught(exception)
+ # end
#
# def perform(record)
# # Will raise ActiveJob::DeserializationError if the record can't be deserialized
+ # # Might raise CustomAppException for something domain specific
# end
# end
def discard_on(exception)
rescue_from exception do |error|
- logger.error "Discarded #{self.class} due to a #{exception}. The original exception was #{error.cause.inspect}."
+ if block_given?
+ yield self, exception
+ else
+ logger.error "Discarded #{self.class} due to a #{exception}. The original exception was #{error.cause.inspect}."
+ end
end
end
end