From d43cf2c5cdf305ea5fe683658d8064f4787a0673 Mon Sep 17 00:00:00 2001 From: Sam Brannen Date: Fri, 13 Oct 2023 18:12:49 +0200 Subject: [PATCH] Polishing --- .../web/filter/reactive/ServerHttpObservationFilter.java | 5 +---- .../web/server/adapter/HttpWebHandlerAdapter.java | 2 +- 2 files changed, 2 insertions(+), 5 deletions(-) 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;