lib/mnemosyne/probes/msgr/consumer.rb in mnemosyne-ruby-1.9.0 vs lib/mnemosyne/probes/msgr/consumer.rb in mnemosyne-ruby-1.10.0.beta1

- old
+ new

@@ -2,20 +2,20 @@ module Mnemosyne module Probes module Msgr module Consumer - NAME = 'app.messaging.receive.msgr'.freeze + NAME = 'app.messaging.receive.msgr' class Probe < ::Mnemosyne::Probe def setup - ::Msgr::Consumer.send :prepend, Instrumentation + ::Msgr::Consumer.prepend Instrumentation end end module Instrumentation - def dispatch(message) # rubocop:disable AbcSize + def dispatch(message) route = message.route metadata = message.metadata headers = metadata.headers || {} delivery_info = message.delivery_info @@ -55,10 +55,10 @@ trace.start! end super rescue StandardError, LoadError, SyntaxError => e - trace.attach_error(e) if trace + trace&.attach_error(e) raise ensure if trace trace.submit trace.release