lib/deimos/base_consumer.rb in deimos-ruby-1.3.0.pre.beta5 vs lib/deimos/base_consumer.rb in deimos-ruby-1.4.0.pre.beta1
- old
+ new
@@ -87,11 +87,11 @@
# @param payload [Hash]
# @param metadata [Hash]
def _handle_error(exception, payload, metadata)
Deimos.config.tracer&.set_error(@span, exception)
- raise if Deimos.config.reraise_consumer_errors ||
- Deimos.config.fatal_error_block.call(exception, payload, metadata) ||
+ raise if Deimos.config.consumers.reraise_errors ||
+ Deimos.config.consumers.fatal_error&.call(exception, payload, metadata) ||
fatal_error?(exception, payload, metadata)
end
# @param _time_taken [Float]
# @param _payload [Hash]