Module: Datadog::Tracing::Contrib::Bunny::Patcher::ChannelPatch

Defined in:
lib/datadog/tracing/contrib/bunny/patcher.rb

Overview

Patch for Bunny::Channel

Instance Method Summary collapse

Instance Method Details

#basic_consume(queue, consumer_tag = generate_consumer_tag, no_ack = false, exclusive = false, arguments = nil, &block) ⇒ Object 



29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/datadog/tracing/contrib/bunny/patcher.rb', line 29

def basic_consume(queue, consumer_tag = generate_consumer_tag, no_ack = false, exclusive = false,
                  arguments = nil, &block)
  config = Datadog.configuration.tracing[:bunny]
  Datadog::Tracing.trace(Ext::SPAN_CONSUME, service: config.service_name) do |span|
    span.type = Datadog::Tracing::Metadata::Ext::AppTypes::TYPE_WORKER
    span.set_tag(Datadog::Tracing::Metadata::Ext::TAG_COMPONENT, Ext::APP)
    span.set_tag(Ext::SPAN_CHANNEL_ID, id)

    super
  end
end

#basic_publish(payload, exchange, routing_key, opts = {}) ⇒ Object 



41
42
43
44
45
46
47
48
49
50
 
# File 'lib/datadog/tracing/contrib/bunny/patcher.rb', line 41

def basic_publish(payload, exchange, routing_key, opts = {})
  config = Datadog.configuration.tracing[:bunny]
  Datadog::Tracing.trace(Ext::SPAN_BASIC_PUBLISH, service: config.service_name) do |span|
    span.type = Datadog::Tracing::Metadata::Ext::AppTypes::TYPE_WORKER
    span.set_tag(Datadog::Tracing::Metadata::Ext::TAG_COMPONENT, Ext::APP)
    span.set_tag(Ext::SPAN_CHANNEL_ID, id)

    super
  end
end