@Bean
public WebsocketRoutingFilter websocketRoutingFilter(WebSocketClient webSocketClient,
		WebSocketService webSocketService,
		ObjectProvider<List<HttpHeadersFilter>> headersFilters) {
	return new WebsocketRoutingFilter(webSocketClient, webSocketService,
			headersFilters);
}
 

public WebsocketRoutingFilter(WebSocketClient webSocketClient,
		WebSocketService webSocketService,
		ObjectProvider<List<HttpHeadersFilter>> headersFiltersProvider) {
	this.webSocketClient = webSocketClient;
	this.webSocketService = webSocketService;
	this.headersFiltersProvider = headersFiltersProvider;
}
 

/**
 * Alternative constructor with the {@link WebSocketService} to use.
 */
public WebSocketHandlerAdapter(WebSocketService webSocketService) {
	Assert.notNull(webSocketService, "'webSocketService' is required");
	this.webSocketService = webSocketService;
}
 

/**
 * Return the configured {@code WebSocketService} to handle requests.
 */
public WebSocketService getWebSocketService() {
	return this.webSocketService;
}
 

@Bean
public WebSocketService webSocketService() {
	return new HandshakeWebSocketService(getUpgradeStrategy());
}
 

/**
 * Alternative constructor with the {@link WebSocketService} to use.
 */
public WebSocketHandlerAdapter(WebSocketService webSocketService) {
	Assert.notNull(webSocketService, "'webSocketService' is required");
	this.webSocketService = webSocketService;
}
 

/**
 * Return the configured {@code WebSocketService} to handle requests.
 */
public WebSocketService getWebSocketService() {
	return this.webSocketService;
}
 

@Bean
public WebSocketService webSocketService() {
	return new HandshakeWebSocketService(getUpgradeStrategy());
}
 

@Bean
public WebSocketService webSocketService() {
    VertxRequestUpgradeStrategy requestUpgradeStrategy = new VertxRequestUpgradeStrategy();
    return new HandshakeWebSocketService(requestUpgradeStrategy);
}
 

@Bean
public WebSocketHandlerAdapter webSocketHandlerAdapter(WebSocketService webSocketService) {
    return new WebSocketHandlerAdapter(webSocketService);
}
 

@Bean
public WebSocketService webSocketService() {
    return new HandshakeWebSocketService(new ReactorNettyRequestUpgradeStrategy());
}
 

@Bean
public WebSocketService webSocketService() {
	return new HandshakeWebSocketService(new ReactorNettyRequestUpgradeStrategy());
}
 

@Bean
public WebSocketService webSocketService(
		RequestUpgradeStrategy requestUpgradeStrategy) {
	return new HandshakeWebSocketService(requestUpgradeStrategy);
}
 

@Bean
public WebSocketService webSocketService() {
	return new HandshakeWebSocketService(getUpgradeStrategy());
}
 

@Bean
public WebSocketService webSocketService() {
	return new HandshakeWebSocketService(new ReactorNettyRequestUpgradeStrategy());
}
 

/**
 * Instantiates a new Web socket plugin.
 *
 * @param webSocketClient  the web socket client
 * @param webSocketService the web socket service
 */
public WebSocketPlugin(final WebSocketClient webSocketClient, final WebSocketService webSocketService) {
    this.webSocketClient = webSocketClient;
    this.webSocketService = webSocketService;
}
 

/**
 * Web socket plugin web socket plugin.
 *
 * @param webSocketClient  the web socket client
 * @param webSocketService the web socket service
 * @return the web socket plugin
 */
@Bean
public WebSocketPlugin webSocketPlugin(final WebSocketClient webSocketClient, final WebSocketService webSocketService) {
    return new WebSocketPlugin(webSocketClient, webSocketService);
}
 

/**
 * Web socket service web socket service.
 *
 * @return the web socket service
 */
@Bean
public WebSocketService webSocketService() {
    return new HandshakeWebSocketService();
}