Module: OpenTelemetry::Instrumentation::Que::Patches::QueJob

Defined in:
lib/opentelemetry/instrumentation/que/patches/que_job.rb

Overview

Module to prepend to Que::Job for instrumentation

Defined Under Namespace

Modules: ClassMethods

Class Method Summary collapse

Class Method Details

.job_attributes(job) ⇒ Object 



55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/opentelemetry/instrumentation/que/patches/que_job.rb', line 55

def self.job_attributes(job)
  attributes = {
    'messaging.system' => 'que',
    'messaging.destination_kind' => 'queue',
    'messaging.operation' => 'send',
    'messaging.destination' => job.que_attrs[:queue] || 'default',
    'messaging.que.job_class' => job.que_attrs[:job_class],
    'messaging.que.priority' => job.que_attrs[:priority] || 100
  }
  attributes['messaging.message_id'] = job.que_attrs[:id] if job.que_attrs[:id]
  attributes
end

.prepended(base) ⇒ Object 



13
14
15
16
17
 
# File 'lib/opentelemetry/instrumentation/que/patches/que_job.rb', line 13

def self.prepended(base)
  class << base
    prepend ClassMethods
  end
end