From 41cb6ae1a5545efa37cb7d72211ee40cad3aae20 Mon Sep 17 00:00:00 2001 From: Jeroen Meijer Date: Mon, 30 Jun 2025 15:05:31 +0200 Subject: [PATCH] Add getter for OverflowStrategy in ConcurrentWebSocketSessionDecorator This commit also includes a test for all configured properties. Closes gh-35132 Signed-off-by: Jeroen Meijer --- .../handler/ConcurrentWebSocketSessionDecorator.java | 7 +++++++ .../ConcurrentWebSocketSessionDecoratorTests.java | 10 ++++++++++ 2 files changed, 17 insertions(+) diff --git a/spring-websocket/src/main/java/org/springframework/web/socket/handler/ConcurrentWebSocketSessionDecorator.java b/spring-websocket/src/main/java/org/springframework/web/socket/handler/ConcurrentWebSocketSessionDecorator.java index d01eed0f8a..5089c22cdb 100644 --- a/spring-websocket/src/main/java/org/springframework/web/socket/handler/ConcurrentWebSocketSessionDecorator.java +++ b/spring-websocket/src/main/java/org/springframework/web/socket/handler/ConcurrentWebSocketSessionDecorator.java @@ -276,6 +276,13 @@ public class ConcurrentWebSocketSessionDecorator extends WebSocketSessionDecorat } } + /** + * Return the configured overflow strategy. + * @since 6.3 + */ + public OverflowStrategy getOverflowStrategy() { + return this.overflowStrategy; + } @Override public String toString() { diff --git a/spring-websocket/src/test/java/org/springframework/web/socket/handler/ConcurrentWebSocketSessionDecoratorTests.java b/spring-websocket/src/test/java/org/springframework/web/socket/handler/ConcurrentWebSocketSessionDecoratorTests.java index 8f8b595e81..da08400d94 100644 --- a/spring-websocket/src/test/java/org/springframework/web/socket/handler/ConcurrentWebSocketSessionDecoratorTests.java +++ b/spring-websocket/src/test/java/org/springframework/web/socket/handler/ConcurrentWebSocketSessionDecoratorTests.java @@ -215,4 +215,14 @@ class ConcurrentWebSocketSessionDecoratorTests { assertThat(latch.await(5, TimeUnit.SECONDS)).isTrue(); } + @Test + void configuredProperties() { + TestWebSocketSession session = new TestWebSocketSession(); + ConcurrentWebSocketSessionDecorator sessionDecorator = new ConcurrentWebSocketSessionDecorator(session, 42, 43, OverflowStrategy.DROP); + + assertThat(sessionDecorator.getSendTimeLimit()).isEqualTo(42); + assertThat(sessionDecorator.getBufferSizeLimit()).isEqualTo(43); + assertThat(sessionDecorator.getOverflowStrategy()).isEqualTo(OverflowStrategy.DROP); + } + }