lib/pwwka/error_handlers/chain.rb in pwwka-0.13.3 vs lib/pwwka/error_handlers/chain.rb in pwwka-0.14.0
- old
+ new
@@ -6,10 +6,10 @@
include Pwwka::Logging
def initialize(default_handler_chain=[])
@error_handlers = default_handler_chain
end
def handle_error(message_handler_klass,receiver,queue_name,payload,delivery_info,exception)
- logf "%{message_handler_klass} has received %{exception}", message_handler_klass: message_handler_klass, exception: exception.message
+ logf "Error Processing Message in %{message_handler_klass} due to %{exception} from payload '%{payload}'", at: :error, message_handler_klass: message_handler_klass, exception: exception.message, payload: payload
if message_handler_klass.respond_to?(:error_handler)
@error_handlers.unshift(message_handler_klass.send(:error_handler))
end
@error_handlers.reduce(true) { |keep_going,error_handler|
logf "%{error_handler_class} is being evaluated as part of pwwka's error-handling chain", error_handler_class: error_handler