From be9ee587aca85152d85a4220a828f8b7ec1e96d5 Mon Sep 17 00:00:00 2001 From: Marcin Grzejszczak Date: Wed, 7 Mar 2018 09:07:53 -0500 Subject: [PATCH] Reverted the temporary async reporter code --- .../cloud/sleuth/zipkin2/ZipkinAutoConfiguration.java | 10 ++-------- 1 file changed, 2 insertions(+), 8 deletions(-) diff --git a/spring-cloud-sleuth-zipkin/src/main/java/org/springframework/cloud/sleuth/zipkin2/ZipkinAutoConfiguration.java b/spring-cloud-sleuth-zipkin/src/main/java/org/springframework/cloud/sleuth/zipkin2/ZipkinAutoConfiguration.java index 81075ecd5..2c64bb7f4 100644 --- a/spring-cloud-sleuth-zipkin/src/main/java/org/springframework/cloud/sleuth/zipkin2/ZipkinAutoConfiguration.java +++ b/spring-cloud-sleuth-zipkin/src/main/java/org/springframework/cloud/sleuth/zipkin2/ZipkinAutoConfiguration.java @@ -85,17 +85,11 @@ public class ZipkinAutoConfiguration { ZipkinProperties zipkin, Sender sender ) { - final AsyncReporter reporter = AsyncReporter.builder(sender).queuedMaxSpans( - 1000) // historical constraint. Note: AsyncReporter supports memory bounds + return AsyncReporter.builder(sender) + .queuedMaxSpans(1000) // historical constraint. Note: AsyncReporter supports memory bounds .messageTimeout(zipkin.getMessageTimeout(), TimeUnit.SECONDS) .metrics(new ReporterMetricsAdapter(spanMetricReporter)) .build(zipkin.getEncoder()); - return new Reporter() { - @Override public void report(Span span) { - reporter.report(span); - reporter.flush(); - } - }; } @Bean