Module: AppPerfRpm::Instruments::EmqueConsuming::Router

Defined in:
lib/app_perf_rpm/instruments/emque_consuming.rb

Instance Method Summary collapse

Instance Method Details

#route_with_trace(topic, type, message) ⇒ Object



5
6
7
8
9
10
11
12
13
14
15
16
# File 'lib/app_perf_rpm/instruments/emque_consuming.rb', line 5

def route_with_trace(topic, type, message)
  action = type.to_s.split(".").last

  ::AppPerfRpm::Tracer.start_trace("emque-consuming", opts) do |span|
    span.controller = topic
    span.action = action
    span.url = "/#{topic}/#{action}"
    span.domain = Socket.gethostname

    route_without_trace(topic, type, message)
  end
end