You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by pa...@apache.org on 2018/09/24 18:13:17 UTC

[camel] branch master updated: Remove (private) dead code in ZipkinTracer.

This is an automated email from the ASF dual-hosted git repository.

pascalschumacher pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new fe4be9b  Remove (private) dead code in ZipkinTracer.
fe4be9b is described below

commit fe4be9b2b65b748d5fd297e136e95fe5f31cdd1f
Author: Pascal Schumacher <pa...@gmx.net>
AuthorDate: Mon Sep 24 20:12:55 2018 +0200

    Remove (private) dead code in ZipkinTracer.
---
 .../src/main/java/org/apache/camel/zipkin/ZipkinTracer.java | 13 +------------
 1 file changed, 1 insertion(+), 12 deletions(-)

diff --git a/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java b/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java
index f069c78..df07d84 100644
--- a/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java
+++ b/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java
@@ -154,7 +154,7 @@ public class ZipkinTracer extends ServiceSupport implements RoutePolicyFactory,
     public RoutePolicy createRoutePolicy(CamelContext camelContext, String routeId, RouteDefinition route) {
         // ensure this zipkin tracer gets initialized when Camel starts
         init(camelContext);
-        return new ZipkinRoutePolicy(routeId);
+        return new ZipkinRoutePolicy();
     }
 
     /**
@@ -713,11 +713,6 @@ public class ZipkinTracer extends ServiceSupport implements RoutePolicyFactory,
         }
     }
 
-    private boolean hasZipkinTraceId(Exchange exchange) {
-        // must have zipkin headers to start a server event
-        return exchange.getIn().getHeader(ZipkinConstants.TRACE_ID) != null;
-    }
-
     private final class ZipkinEventNotifier extends EventNotifierSupport {
 
         @Override
@@ -760,12 +755,6 @@ public class ZipkinTracer extends ServiceSupport implements RoutePolicyFactory,
 
     private final class ZipkinRoutePolicy extends RoutePolicySupport {
 
-        private final String routeId;
-
-        ZipkinRoutePolicy(String routeId) {
-            this.routeId = routeId;
-        }
-
         @Override
         public void onExchangeBegin(Route route, Exchange exchange) {
             // use route policy to track events when Camel a Camel route begins/end the lifecycle of an Exchange