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_attrs) ⇒ Object 



72
73
74
75
76
77
78
79
80
81
82
83
 
# File 'lib/opentelemetry/instrumentation/que/patches/que_job.rb', line 72

def self.job_attributes(job_attrs)
  attributes = {
    'messaging.system' => 'que',
    'messaging.destination_kind' => 'queue',
    'messaging.operation' => 'publish',
    'messaging.destination' => job_attrs[:queue] || 'default',
    'messaging.que.job_class' => job_attrs[:job_class],
    'messaging.que.priority' => job_attrs[:priority] || 100
  }
  attributes['messaging.message_id'] = job_attrs[:id] if job_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