File tree Expand file tree Collapse file tree 1 file changed +13
-12
lines changed
exporters/zipkin/src/main/java/io/opentelemetry/exporter/zipkin Expand file tree Collapse file tree 1 file changed +13
-12
lines changed Original file line number Diff line number Diff line change 55
66package io .opentelemetry .exporter .zipkin ;
77
8+ import io .opentelemetry .api .internal .InstrumentationUtil ;
89import io .opentelemetry .api .metrics .MeterProvider ;
910import io .opentelemetry .exporter .internal .ExporterMetrics ;
10- import io .opentelemetry .exporter .internal .InstrumentationUtil ;
1111import io .opentelemetry .sdk .common .CompletableResultCode ;
1212import io .opentelemetry .sdk .internal .ThrottlingLogger ;
1313import io .opentelemetry .sdk .trace .data .SpanData ;
@@ -77,17 +77,18 @@ public CompletableResultCode export(Collection<SpanData> spanDataList) {
7777 }
7878
7979 CompletableResultCode resultCode = new CompletableResultCode ();
80- InstrumentationUtil .suppressInstrumentation (() -> {
81- try {
82- sender .send (encodedSpans );
83- exporterMetrics .addSuccess (numItems );
84- resultCode .succeed ();
85- } catch (IOException | RuntimeException e ) {
86- exporterMetrics .addFailed (numItems );
87- logger .log (Level .WARNING , "Failed to export spans" , e );
88- resultCode .fail ();
89- }
90- });
80+ InstrumentationUtil .suppressInstrumentation (
81+ () -> {
82+ try {
83+ sender .send (encodedSpans );
84+ exporterMetrics .addSuccess (numItems );
85+ resultCode .succeed ();
86+ } catch (IOException | RuntimeException e ) {
87+ exporterMetrics .addFailed (numItems );
88+ logger .log (Level .WARNING , "Failed to export spans" , e );
89+ resultCode .fail ();
90+ }
91+ });
9192 return resultCode ;
9293 }
9394
You can’t perform that action at this time.
0 commit comments