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