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