public class TomcatRequestUpgradeStrategy extends java.lang.Object implements RequestUpgradeStrategy
RequestUpgradeStrategy
for use with Tomcat.Modifier and Type | Field and Description |
---|---|
private java.lang.Long |
asyncSendTimeout |
private java.lang.Integer |
maxBinaryMessageBufferSize |
private java.lang.Long |
maxSessionIdleTimeout |
private java.lang.Integer |
maxTextMessageBufferSize |
private static java.lang.String |
SERVER_CONTAINER_ATTR |
private WsServerContainer |
serverContainer |
Constructor and Description |
---|
TomcatRequestUpgradeStrategy() |
Modifier and Type | Method and Description |
---|---|
java.lang.Long |
getAsyncSendTimeout() |
private WsServerContainer |
getContainer(HttpServletRequest request) |
private HttpServletRequest |
getHttpServletRequest(ServerHttpRequest request) |
private HttpServletResponse |
getHttpServletResponse(ServerHttpResponse response) |
java.lang.Integer |
getMaxBinaryMessageBufferSize() |
java.lang.Long |
getMaxSessionIdleTimeout() |
java.lang.Integer |
getMaxTextMessageBufferSize() |
private void |
initServerContainer(ServerContainer serverContainer) |
void |
setAsyncSendTimeout(java.lang.Long timeoutInMillis)
Exposes the underlying config option on
javax.websocket.server.ServerContainer#setAsyncSendTimeout(long) . |
void |
setMaxBinaryMessageBufferSize(java.lang.Integer bufferSize)
Exposes the underlying config option on
javax.websocket.server.ServerContainer#setDefaultMaxBinaryMessageBufferSize(int) . |
void |
setMaxSessionIdleTimeout(java.lang.Long timeoutInMillis)
Exposes the underlying config option on
javax.websocket.server.ServerContainer#setDefaultMaxSessionIdleTimeout(long) . |
void |
setMaxTextMessageBufferSize(java.lang.Integer bufferSize)
Exposes the underlying config option on
javax.websocket.server.ServerContainer#setDefaultMaxTextMessageBufferSize(int) . |
<any> |
upgrade(ServerWebExchange exchange,
WebSocketHandler handler,
java.lang.String subProtocol,
java.util.function.Supplier<HandshakeInfo> handshakeInfoFactory)
Upgrade to a WebSocket session and handle it with the given handler.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
upgrade
private static final java.lang.String SERVER_CONTAINER_ATTR
@Nullable private java.lang.Long asyncSendTimeout
@Nullable private java.lang.Long maxSessionIdleTimeout
@Nullable private java.lang.Integer maxTextMessageBufferSize
@Nullable private java.lang.Integer maxBinaryMessageBufferSize
@Nullable private WsServerContainer serverContainer
public void setAsyncSendTimeout(java.lang.Long timeoutInMillis)
javax.websocket.server.ServerContainer#setAsyncSendTimeout(long)
.@Nullable public java.lang.Long getAsyncSendTimeout()
public void setMaxSessionIdleTimeout(java.lang.Long timeoutInMillis)
javax.websocket.server.ServerContainer#setDefaultMaxSessionIdleTimeout(long)
.@Nullable public java.lang.Long getMaxSessionIdleTimeout()
public void setMaxTextMessageBufferSize(java.lang.Integer bufferSize)
javax.websocket.server.ServerContainer#setDefaultMaxTextMessageBufferSize(int)
.@Nullable public java.lang.Integer getMaxTextMessageBufferSize()
public void setMaxBinaryMessageBufferSize(java.lang.Integer bufferSize)
javax.websocket.server.ServerContainer#setDefaultMaxBinaryMessageBufferSize(int)
.@Nullable public java.lang.Integer getMaxBinaryMessageBufferSize()
public <any> upgrade(ServerWebExchange exchange, WebSocketHandler handler, @Nullable java.lang.String subProtocol, java.util.function.Supplier<HandshakeInfo> handshakeInfoFactory)
RequestUpgradeStrategy
upgrade
in interface RequestUpgradeStrategy
exchange
- the current exchangehandler
- handler for the WebSocket sessionsubProtocol
- the selected sub-protocol got the handlerhandshakeInfoFactory
- factory to create HandshakeInfo for the WebSocket sessionMono<Void>
to indicate the outcome of the
WebSocket session handling.private HttpServletRequest getHttpServletRequest(ServerHttpRequest request)
private HttpServletResponse getHttpServletResponse(ServerHttpResponse response)
private WsServerContainer getContainer(HttpServletRequest request)
private void initServerContainer(ServerContainer serverContainer)