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

liubao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/servicecomb-java-chassis.git


The following commit(s) were added to refs/heads/master by this push:
     new f30571695 [#4035] fix invocation context loss issue (#4087)
f30571695 is described below

commit f3057169528c686501f6cd2595c45b75579dd1d0
Author: yanghao <[email protected]>
AuthorDate: Mon Dec 11 09:32:13 2023 +0800

    [#4035] fix invocation context loss issue (#4087)
---
 .../servicecomb/tracing/zipkin/ZipkinTracingFilter.java   | 15 ++++-----------
 1 file changed, 4 insertions(+), 11 deletions(-)

diff --git 
a/handlers/handler-tracing-zipkin/src/main/java/org/apache/servicecomb/tracing/zipkin/ZipkinTracingFilter.java
 
b/handlers/handler-tracing-zipkin/src/main/java/org/apache/servicecomb/tracing/zipkin/ZipkinTracingFilter.java
index 9f162f648..4bc8f415e 100644
--- 
a/handlers/handler-tracing-zipkin/src/main/java/org/apache/servicecomb/tracing/zipkin/ZipkinTracingFilter.java
+++ 
b/handlers/handler-tracing-zipkin/src/main/java/org/apache/servicecomb/tracing/zipkin/ZipkinTracingFilter.java
@@ -37,21 +37,14 @@ import brave.http.HttpTracing;
 public class ZipkinTracingFilter extends AbstractFilter implements 
ConsumerFilter, ProviderFilter {
   public static final String NAME = "zipkin";
 
-  private ZipkinConsumerDelegate consumer;
-
-  private ZipkinProviderDelegate producer;
+  @Autowired
+  private HttpTracing httpTracing;
 
   @Override
   public String getName() {
     return NAME;
   }
 
-  @Autowired
-  public void setHttpTracing(HttpTracing httpTracing) {
-    this.consumer = new ZipkinConsumerDelegate(httpTracing);
-    this.producer = new ZipkinProviderDelegate(httpTracing);
-  }
-
   @SuppressWarnings({"try", "unused"})
   @Override
   public CompletableFuture<Response> onFilter(Invocation invocation, 
FilterNode nextNode) {
@@ -66,9 +59,9 @@ public class ZipkinTracingFilter extends AbstractFilter 
implements ConsumerFilte
 
   private ZipkinTracingDelegate collectTracing(Invocation invocation) {
     if (PROVIDER.equals(invocation.getInvocationType())) {
-      return producer;
+      return new ZipkinProviderDelegate(httpTracing);
     }
 
-    return consumer;
+    return new ZipkinConsumerDelegate(httpTracing);
   }
 }

Reply via email to