Package org.springframework.web.reactive.socket.server.upgrade

Class JettyCoreRequestUpgradeStrategy

java.lang.Object

org.springframework.web.reactive.socket.server.upgrade.JettyCoreRequestUpgradeStrategy

All Implemented Interfaces:

RequestUpgradeStrategy

public class JettyCoreRequestUpgradeStrategy
extends Object
implements RequestUpgradeStrategy

A WebSocket RequestUpgradeStrategy for Jetty 12 Core.

Since:

6.2

Author:

Rossen Stoyanchev, Greg Wilkins

Constructor Summary

Constructors

Constructor	Description
JettyCoreRequestUpgradeStrategy()

Method Summary

Modifier and Type	Method	Description
void	addWebSocketConfigurer(Consumer<org.eclipse.jetty.websocket.api.Configurable> webSocketConfigurer)	Add a callback to configure WebSocket server parameters on JettyWebSocketServerContainer.
reactor.core.publisher.Mono<Void>	upgrade(ServerWebExchange exchange, WebSocketHandler handler, String subProtocol, Supplier<HandshakeInfo> handshakeInfoFactory)	Upgrade to a WebSocket session and handle it with the given handler.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JettyCoreRequestUpgradeStrategy

public JettyCoreRequestUpgradeStrategy()

Method Details

addWebSocketConfigurer

public void addWebSocketConfigurer(Consumer<org.eclipse.jetty.websocket.api.Configurable> webSocketConfigurer)

Add a callback to configure WebSocket server parameters on JettyWebSocketServerContainer.

upgrade

public reactor.core.publisher.Mono<Void> upgrade(ServerWebExchange exchange,
 WebSocketHandler handler,
 @Nullable
 String subProtocol,
 Supplier<HandshakeInfo> handshakeInfoFactory)

Description copied from interface: RequestUpgradeStrategy

Upgrade to a WebSocket session and handle it with the given handler.

Specified by:

upgrade in interface RequestUpgradeStrategy

Parameters:

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

Returns:

completion Mono<Void> to indicate the outcome of the WebSocket session handling.