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]