Contents

module Eventboss
  # :nodoc:
  module Instrumentation
    def self.add(queue_listeners)
      return unless defined?(::NewRelic::Agent::Instrumentation::ControllerInstrumentation)
      Eventboss::Instrumentation::NewRelic.install(queue_listeners)
    end

    # :nodoc:
    module NewRelic
      def self.install(queue_listeners)
        Eventboss.logger.info('Loaded NewRelic instrumentation')
        queue_listeners.each_value do |listener_class|
          listener_class.include(::NewRelic::Agent::Instrumentation::ControllerInstrumentation)
          listener_class.add_transaction_tracer(:receive, category: 'OtherTransaction/EventbossJob')
        end

        Eventboss::Sender.include(::NewRelic::Agent::MethodTracer)
        Eventboss::Sender.add_method_tracer(:send_batch, 'Eventboss/sender_send_batch')

        Eventboss::Publisher.include(::NewRelic::Agent::MethodTracer)
        Eventboss::Publisher.add_method_tracer(:publish, 'Eventboss/publisher_publish')
      end
    end
  end
end

Version data entries

17 entries across 17 versions & 1 rubygems

Version	Path
eventboss-1.9.2	lib/eventboss/instrumentation.rb
eventboss-1.9.1	lib/eventboss/instrumentation.rb
eventboss-1.9.0	lib/eventboss/instrumentation.rb
eventboss-1.8.1	lib/eventboss/instrumentation.rb
eventboss-1.8.0	lib/eventboss/instrumentation.rb
eventboss-1.7.0	lib/eventboss/instrumentation.rb
eventboss-1.5.0	lib/eventboss/instrumentation.rb
eventboss-1.4.1	lib/eventboss/instrumentation.rb
eventboss-1.3.5	lib/eventboss/instrumentation.rb
eventboss-1.3.4	lib/eventboss/instrumentation.rb
eventboss-1.3.3	lib/eventboss/instrumentation.rb
eventboss-1.3.2	lib/eventboss/instrumentation.rb
eventboss-1.3.1	lib/eventboss/instrumentation.rb
eventboss-1.3.0	lib/eventboss/instrumentation.rb
eventboss-1.2.1	lib/eventboss/instrumentation.rb
eventboss-1.2.0	lib/eventboss/instrumentation.rb
eventboss-1.1.3	lib/eventboss/instrumentation.rb