You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2019/12/04 09:12:40 UTC
[camel] 04/04: CAMEL-14253: camel-nats - Configure brokers on
component level
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 <cl...@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);
}