Implement messageSize methods in JettyWebSocketSession
Closes gh-28325
This commit is contained in:
parent
8ca82120e0
commit
0e6e225fb9
|
@ -142,11 +142,10 @@ public class JettyWebSocketSession extends AbstractWebSocketSession<Session> {
|
||||||
return (InetSocketAddress) getNativeSession().getRemoteSocketAddress();
|
return (InetSocketAddress) getNativeSession().getRemoteSocketAddress();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* This method is a no-op for Jetty.
|
|
||||||
*/
|
|
||||||
@Override
|
@Override
|
||||||
public void setTextMessageSizeLimit(int messageSizeLimit) {
|
public void setTextMessageSizeLimit(int messageSizeLimit) {
|
||||||
|
checkNativeSessionInitialized();
|
||||||
|
getNativeSession().setMaxTextMessageSize(messageSizeLimit);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
@ -155,11 +154,10 @@ public class JettyWebSocketSession extends AbstractWebSocketSession<Session> {
|
||||||
return (int) getNativeSession().getMaxTextMessageSize();
|
return (int) getNativeSession().getMaxTextMessageSize();
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
|
||||||
* This method is a no-op for Jetty.
|
|
||||||
*/
|
|
||||||
@Override
|
@Override
|
||||||
public void setBinaryMessageSizeLimit(int messageSizeLimit) {
|
public void setBinaryMessageSizeLimit(int messageSizeLimit) {
|
||||||
|
checkNativeSessionInitialized();
|
||||||
|
getNativeSession().setMaxBinaryMessageSize(messageSizeLimit);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|
Loading…
Reference in New Issue