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 2020/07/29 14:37:09 UTC
[camel] 01/02: CAMEL-15230 - remove overriden method getDestination
as exchange name header not required and absence results in null operation
name
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.4.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2d37e722991b8885b0f1a683a1769c61241a373a
Author: Matthew Robbins <ma...@telegraph.co.uk>
AuthorDate: Tue Jun 30 09:46:37 2020 +0100
CAMEL-15230 - remove overriden method getDestination as exchange name header not required and absence results in null operation name
---
.../camel/opentracing/decorators/RabbitmqSpanDecorator.java | 13 -------------
1 file changed, 13 deletions(-)
diff --git a/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/decorators/RabbitmqSpanDecorator.java b/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/decorators/RabbitmqSpanDecorator.java
index 1d47fb3..d741744 100644
--- a/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/decorators/RabbitmqSpanDecorator.java
+++ b/components/camel-opentracing/src/main/java/org/apache/camel/opentracing/decorators/RabbitmqSpanDecorator.java
@@ -16,16 +16,8 @@
*/
package org.apache.camel.opentracing.decorators;
-import org.apache.camel.Endpoint;
-import org.apache.camel.Exchange;
-
public class RabbitmqSpanDecorator extends AbstractMessagingSpanDecorator {
- /**
- * Constants copied from {@link org.apache.camel.component.rabbitmq.RabbitMQConstants}
- */
- protected static final String EXCHANGE_NAME = "rabbitmq.EXCHANGE_NAME";
-
@Override
public String getComponent() {
return "rabbitmq";
@@ -36,9 +28,4 @@ public class RabbitmqSpanDecorator extends AbstractMessagingSpanDecorator {
return "org.apache.camel.component.rabbitmq.RabbitMQComponent";
}
- @Override
- public String getDestination(Exchange exchange, Endpoint endpoint) {
- return (String)exchange.getIn().getHeader(EXCHANGE_NAME);
- }
-
}