diff options
author | Aidan Haran <aidanharan@Aidans-MacBook-Pro.local> | 2017-09-16 19:59:32 +0100 |
---|---|---|
committer | Aidan Haran <aidanharan@Aidans-MacBook-Pro.local> | 2017-09-16 19:59:32 +0100 |
commit | 3291fa3630c456450f8c6a9b771f77c293d036cd (patch) | |
tree | d8b3a6311df9b233955209d6c33f0fa07c2c7285 /activejob/lib/active_job/exceptions.rb | |
parent | 34956f7422798f27f8926544d58771042f6f1c3a (diff) | |
download | rails-3291fa3630c456450f8c6a9b771f77c293d036cd.tar.gz rails-3291fa3630c456450f8c6a9b771f77c293d036cd.tar.bz2 rails-3291fa3630c456450f8c6a9b771f77c293d036cd.zip |
Allow for custom handling of exceptions that are discarded
Diffstat (limited to 'activejob/lib/active_job/exceptions.rb')
-rw-r--r-- | activejob/lib/active_job/exceptions.rb | 12 |
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 |