diff --git a/spring-web/src/main/java/org/springframework/web/filter/reactive/ServerHttpObservationFilter.java b/spring-web/src/main/java/org/springframework/web/filter/reactive/ServerHttpObservationFilter.java index b875ccbfad..897aedf068 100644 --- a/spring-web/src/main/java/org/springframework/web/filter/reactive/ServerHttpObservationFilter.java +++ b/spring-web/src/main/java/org/springframework/web/filter/reactive/ServerHttpObservationFilter.java @@ -62,9 +62,6 @@ public class ServerHttpObservationFilter implements WebFilter { private static final ServerRequestObservationConvention DEFAULT_OBSERVATION_CONVENTION = new DefaultServerRequestObservationConvention(); - private static final Set DISCONNECTED_CLIENT_EXCEPTIONS = Set.of("AbortedException", - "ClientAbortException", "EOFException", "EofException"); - private final ObservationRegistry observationRegistry; private final ServerRequestObservationConvention observationConvention; @@ -116,7 +113,7 @@ public class ServerHttpObservationFilter implements WebFilter { private final Observation observation; - private AtomicBoolean observationRecorded = new AtomicBoolean(); + private final AtomicBoolean observationRecorded = new AtomicBoolean(); public ObservationSignalListener(ServerRequestObservationContext observationContext) { this.observationContext = observationContext; diff --git a/spring-web/src/main/java/org/springframework/web/server/adapter/HttpWebHandlerAdapter.java b/spring-web/src/main/java/org/springframework/web/server/adapter/HttpWebHandlerAdapter.java index a3147d8eda..f8ac4cccac 100644 --- a/spring-web/src/main/java/org/springframework/web/server/adapter/HttpWebHandlerAdapter.java +++ b/spring-web/src/main/java/org/springframework/web/server/adapter/HttpWebHandlerAdapter.java @@ -389,7 +389,7 @@ public class HttpWebHandlerAdapter extends WebHandlerDecorator implements HttpHa private final Observation observation; - private AtomicBoolean observationRecorded = new AtomicBoolean(); + private final AtomicBoolean observationRecorded = new AtomicBoolean(); public ObservationSignalListener(ServerRequestObservationContext observationContext) { this.observationContext = observationContext;