lib/new_relic/agent/instrumentation/bunny/instrumentation.rb in newrelic_rpm-8.2.0 vs lib/new_relic/agent/instrumentation/bunny/instrumentation.rb in newrelic_rpm-8.3.0
- old
+ new
@@ -10,11 +10,11 @@
module_function
LIBRARY = 'RabbitMQ'
DEFAULT_NAME = 'Default'
DEFAULT_TYPE = :direct
- SLASH = '/'
+ SLASH = '/'
def exchange_name name
name.empty? ? DEFAULT_NAME : name
end
@@ -72,15 +72,15 @@
bunny_error = error
end
begin
exch_name, exch_type = if delivery_info
- [ exchange_name(delivery_info.exchange),
- exchange_type(delivery_info, channel) ]
+ [exchange_name(delivery_info.exchange),
+ exchange_type(delivery_info, channel)]
else
- [ exchange_name(NewRelic::EMPTY_STR),
- exchange_type({}, channel) ]
+ [exchange_name(NewRelic::EMPTY_STR),
+ exchange_type({}, channel)]
end
segment = NewRelic::Agent::Messaging.start_amqp_consume_segment(
library: LIBRARY,
destination_name: exch_name,
@@ -137,15 +137,14 @@
library: LIBRARY,
destination_name: exchange_name(delivery_info.exchange),
delivery_info: delivery_info,
message_properties: message_properties,
exchange_type: exchange_type(delivery_info, channel),
- queue_name: queue_name) do
-
+ queue_name: queue_name
+ ) do
yield
end
end
-
end
end
end
end
end