This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 17552976c0692a4b34536c484b2e3d24be1b3f9c Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Wed Dec 4 10:12:14 2019 +0100 CAMEL-14253: camel-nats - Configure brokers on component level --- .../apache/camel/opentracing/decorators/NatsSpanDecorator.java | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/decorators/NatsSpanDecorator.java b/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/decorators/NatsSpanDecorator.java index dfa3262..0882576 100644 --- a/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/decorators/NatsSpanDecorator.java +++ b/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/decorators/NatsSpanDecorator.java @@ -16,9 +16,6 @@ */ package org.apache.camel.opentracing.decorators; -import java.util.Map; - -import org.apache.camel.Endpoint; import org.apache.camel.Exchange; public class NatsSpanDecorator extends AbstractMessagingSpanDecorator { @@ -36,13 +33,6 @@ public class NatsSpanDecorator extends AbstractMessagingSpanDecorator { } @Override - public String getDestination(Exchange exchange, Endpoint endpoint) { - Map<String, String> queryParameters = toQueryParameters(endpoint.getEndpointUri()); - String topic = queryParameters.get("topic"); - return topic != null ? topic : super.getDestination(exchange, endpoint); - } - - @Override protected String getMessageId(Exchange exchange) { return exchange.getIn().getHeader(NATS_SID, String.class); }