diff --git a/spring-websocket/src/main/java/org/springframework/web/socket/adapter/jetty/JettyWebSocketSession.java b/spring-websocket/src/main/java/org/springframework/web/socket/adapter/jetty/JettyWebSocketSession.java index 883f913589..f365f717f0 100644 --- a/spring-websocket/src/main/java/org/springframework/web/socket/adapter/jetty/JettyWebSocketSession.java +++ b/spring-websocket/src/main/java/org/springframework/web/socket/adapter/jetty/JettyWebSocketSession.java @@ -142,11 +142,10 @@ public class JettyWebSocketSession extends AbstractWebSocketSession { return (InetSocketAddress) getNativeSession().getRemoteSocketAddress(); } - /** - * This method is a no-op for Jetty. - */ @Override public void setTextMessageSizeLimit(int messageSizeLimit) { + checkNativeSessionInitialized(); + getNativeSession().setMaxTextMessageSize(messageSizeLimit); } @Override @@ -155,11 +154,10 @@ public class JettyWebSocketSession extends AbstractWebSocketSession { return (int) getNativeSession().getMaxTextMessageSize(); } - /** - * This method is a no-op for Jetty. - */ @Override public void setBinaryMessageSizeLimit(int messageSizeLimit) { + checkNativeSessionInitialized(); + getNativeSession().setMaxBinaryMessageSize(messageSizeLimit); } @Override