SpringCloud/spring-cloud-sleuth
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reverted the temporary async reporter code

Browse Source
This commit is contained in:
Marcin Grzejszczak
2018-03-07 09:07:53 -05:00
parent 433e7c301a
commit be9ee587ac
1 changed files with 2 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
spring-cloud-sleuth-zipkin/src/main/java/org/springframework/cloud/sleuth/zipkin2/ZipkinAutoConfiguration.java
View File

@@ -85,17 +85,11 @@ public class ZipkinAutoConfiguration {
ZipkinProperties zipkin,
Sender sender
) {
final AsyncReporter<Span> 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<Span>() {
@Override public void report(Span span) {
reporter.report(span);
reporter.flush();
}
};
}
@Bean