File tree 1 file changed +13
-12
lines changed
exporters/zipkin/src/main/java/io/opentelemetry/exporter/zipkin
1 file changed +13
-12
lines changed Original file line number Diff line number Diff line change 5
5
6
6
package io .opentelemetry .exporter .zipkin ;
7
7
8
+ import io .opentelemetry .api .internal .InstrumentationUtil ;
8
9
import io .opentelemetry .api .metrics .MeterProvider ;
9
10
import io .opentelemetry .exporter .internal .ExporterMetrics ;
10
- import io .opentelemetry .exporter .internal .InstrumentationUtil ;
11
11
import io .opentelemetry .sdk .common .CompletableResultCode ;
12
12
import io .opentelemetry .sdk .internal .ThrottlingLogger ;
13
13
import io .opentelemetry .sdk .trace .data .SpanData ;
@@ -77,17 +77,18 @@ public CompletableResultCode export(Collection<SpanData> spanDataList) {
77
77
}
78
78
79
79
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
+ });
91
92
return resultCode ;
92
93
}
93
94
You can’t perform that action at this time.
0 commit comments