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 |