public class JettyRequestUpgradeStrategy extends Object implements RequestUpgradeStrategy, Lifecycle
RequestUpgradeStrategyfor use with Jetty.
|Constructor and Description|
|Modifier and Type||Method and Description|
Return the configured
Check whether this component is currently running.
Start this component.
Stop this component, typically in a synchronous fashion, such that the component is fully stopped upon return of this method.
Upgrade to a WebSocket session and handle it with the given handler.
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public void setWebSocketPolicy(org.eclipse.jetty.websocket.api.WebSocketPolicy webSocketPolicy)
WebSocketPolicyto use to initialize
webSocketPolicy- the WebSocket settings
@Nullable public org.eclipse.jetty.websocket.api.WebSocketPolicy getWebSocketPolicy()
WebSocketPolicy, if any.
public void start()
Should not throw an exception if the component is already running.
In the case of a container, this will propagate the start signal to all components that apply.
public void stop()
stop(Runnable)variant when asynchronous stop behavior is necessary.
Note that this stop notification is not guaranteed to come before destruction:
On regular shutdown,
Lifecycle beans will first receive a stop notification
before the general destruction callbacks are being propagated; however, on hot
refresh during a context's lifetime or on aborted refresh attempts, a given bean's
destroy method will be called without any consideration of stop signals upfront.
Should not throw an exception if the component is not running (not started yet).
In the case of a container, this will propagate the stop signal to all components that apply.
public boolean isRunning()
In the case of a container, this will return
true only if all
components that apply are currently running.
public reactor.core.publisher.Mono<Void> upgrade(ServerWebExchange exchange, WebSocketHandler handler, @Nullable String subProtocol, Supplier<HandshakeInfo> handshakeInfoFactory)
exchange- the current exchange
handler- handler for the WebSocket session
subProtocol- the selected sub-protocol got the handler
handshakeInfoFactory- factory to create HandshakeInfo for the WebSocket session
Mono<Void>to indicate the outcome of the WebSocket session handling.