Skip to content

Commit 663e799

Browse files
authored
Merge pull request #48599 from geoand/OpenTelemetryDestroyer-polish
Polish OpenTelemetryDestroyer
2 parents 6a7dc43 + 28429c6 commit 663e799

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

extensions/opentelemetry/runtime/src/main/java/io/quarkus/opentelemetry/OpenTelemetryDestroyer.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -18,10 +18,9 @@ public class OpenTelemetryDestroyer implements BeanDestroyer<OpenTelemetry> {
1818
@Override
1919
public void destroy(OpenTelemetry openTelemetry, CreationalContext<OpenTelemetry> creationalContext,
2020
Map<String, Object> params) {
21-
if (openTelemetry instanceof OpenTelemetrySdk) {
21+
if (openTelemetry instanceof OpenTelemetrySdk openTelemetrySdk) {
2222
// between flush and shutdown we will wait shutdown-wait-time, at the most.
2323
var waitTime = getShutdownWaitTime().dividedBy(4);
24-
var openTelemetrySdk = ((OpenTelemetrySdk) openTelemetry);
2524
openTelemetrySdk.getSdkLoggerProvider().forceFlush().join(waitTime.toMillis(), MILLISECONDS);
2625
openTelemetrySdk.getSdkTracerProvider().forceFlush().join(waitTime.toMillis(), MILLISECONDS);
2726
openTelemetrySdk.getSdkMeterProvider().forceFlush().join(waitTime.toMillis(), MILLISECONDS);
@@ -31,8 +30,7 @@ public void destroy(OpenTelemetry openTelemetry, CreationalContext<OpenTelemetry
3130

3231
public static Duration getShutdownWaitTime() {
3332
var config = ConfigProvider.getConfig().unwrap(SmallRyeConfig.class);
34-
var waitTime = config.getOptionalValue("quarkus.otel.experimental.shutdown-wait-time", Duration.class)
33+
return config.getOptionalValue("quarkus.otel.experimental.shutdown-wait-time", Duration.class)
3534
.orElse(Duration.ofSeconds(2));
36-
return waitTime;
3735
}
3836
}

0 commit comments

Comments
 (0)