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