module OpenTelemetry::Instrumentation::Que::Patches::QueJob

def self.job_attributes(job_attrs)
  attributes = {
    'messaging.system' => 'que',
    'messaging.destination_kind' => 'queue',
    'messaging.operation' => 'send',
    '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