diff --git a/spring-graphql/src/main/java/org/springframework/graphql/server/webmvc/GraphQlWebSocketHandler.java b/spring-graphql/src/main/java/org/springframework/graphql/server/webmvc/GraphQlWebSocketHandler.java index f4f397f2..588be8e5 100644 --- a/spring-graphql/src/main/java/org/springframework/graphql/server/webmvc/GraphQlWebSocketHandler.java +++ b/spring-graphql/src/main/java/org/springframework/graphql/server/webmvc/GraphQlWebSocketHandler.java @@ -365,12 +365,9 @@ public class GraphQlWebSocketHandler extends TextWebSocketHandler implements Sub public Closeable restoreThreadLocalValue(WebSocketSession session) { if (this.accessor != null) { Map valuesMap = (Map) session.getAttributes().get(SAVED_CONTEXT_KEY); - // Uncomment when Boot is updated to use HandshakeInterceptor - // Assert.state(valuesMap != null, "No context"); - if (valuesMap != null) { - this.accessor.restoreValues(valuesMap); - return () -> this.accessor.resetValues(valuesMap); - } + Assert.state(valuesMap != null, "No ThreadLocal context in WebSocketSession attributes"); + this.accessor.restoreValues(valuesMap); + return () -> this.accessor.resetValues(valuesMap); } return () -> {}; }