Skip to content

Commit

Permalink
Merge branch 'main' into add-conventional-commit-linters
Browse files Browse the repository at this point in the history
  • Loading branch information
arielvalentin authored Jan 26, 2024
2 parents 49ba8ea + 66f1786 commit 911fe50
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,12 +19,12 @@ def self.with_send_span(channel, tracer, exchange, routing_key, &block)
tracer.in_span("#{destination} publish", attributes: attributes, kind: :producer, &block)
end

def self.with_process_span(channel, tracer, delivery_info, properties, &block) # rubocop:disable Style/ArgumentsForwarding
def self.with_process_span(channel, tracer, delivery_info, properties, &block)
destination = destination_name(delivery_info[:exchange], delivery_info[:routing_key])
parent_context, links = extract_context(properties)

OpenTelemetry::Context.with_current(parent_context) do
tracer.in_span("#{destination} process", links: links, kind: :consumer, &block) # rubocop:disable Style/ArgumentsForwarding
tracer.in_span("#{destination} process", links: links, kind: :consumer, &block)
end
end

Expand Down

0 comments on commit 911fe50

Please sign in to comment.