org.springframework.web.socket.client.standard

Class StandardWebSocketClient

java.lang.Object

org.springframework.web.socket.client.AbstractWebSocketClient

org.springframework.web.socket.client.standard.StandardWebSocketClient

All Implemented Interfaces:

WebSocketClient

public class StandardWebSocketClient
extends AbstractWebSocketClient

Initiates WebSocket requests to a WebSocket server programatically through the standard Java WebSocket API.

Since:

4.0

Author:

Rossen Stoyanchev

Field Summary

Fields inherited from class org.springframework.web.socket.client.AbstractWebSocketClient

logger

Constructor Summary

Constructors

Constructor and Description
StandardWebSocketClient() Default constructor that calls ContainerProvider.getWebSocketContainer() to obtain a WebSocketContainer instance.
StandardWebSocketClient(javax.websocket.WebSocketContainer webSocketContainer) Constructor that accepts a pre-configured WebSocketContainer instance.

Method Summary

Modifier and Type	Method and Description
protected ListenableFuture<WebSocketSession>	doHandshakeInternal(WebSocketHandler webSocketHandler, HttpHeaders headers, URI uri, List<String> protocols, List<WebSocketExtension> extensions, Map<String,Object> handshakeAttributes) Perform the actual handshake to establish a connection to the server.
AsyncListenableTaskExecutor	getTaskExecutor() Return the configured TaskExecutor.
void	setTaskExecutor(AsyncListenableTaskExecutor taskExecutor) Set a TaskExecutor to use to open the connection.

Methods inherited from class org.springframework.web.socket.client.AbstractWebSocketClient

doHandshake, doHandshake

Methods inherited from class java.lang.Object

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

Constructor Detail

StandardWebSocketClient

public StandardWebSocketClient()

Default constructor that calls ContainerProvider.getWebSocketContainer() to obtain a WebSocketContainer instance.

StandardWebSocketClient

public StandardWebSocketClient(javax.websocket.WebSocketContainer webSocketContainer)

Constructor that accepts a pre-configured WebSocketContainer instance. If using XML configuration see WebSocketContainerFactoryBean. In Java configuration use ContainerProvider.getWebSocketContainer() to obtain a container instance.

Method Detail

setTaskExecutor

public void setTaskExecutor(AsyncListenableTaskExecutor taskExecutor)

Set a TaskExecutor to use to open the connection. By default SimpleAsyncTaskExecutor is used.

getTaskExecutor

public AsyncListenableTaskExecutor getTaskExecutor()

Return the configured TaskExecutor.

doHandshakeInternal

protected ListenableFuture<WebSocketSession> doHandshakeInternal(WebSocketHandler webSocketHandler,
                                                                 HttpHeaders headers,
                                                                 URI uri,
                                                                 List<String> protocols,
                                                                 List<WebSocketExtension> extensions,
                                                                 Map<String,Object> handshakeAttributes)

Description copied from class: AbstractWebSocketClient

Perform the actual handshake to establish a connection to the server.

Specified by:

doHandshakeInternal in class AbstractWebSocketClient

Parameters:

webSocketHandler - the client-side handler for WebSocket messages

headers - HTTP headers to use for the handshake, with unwanted (forbidden) headers filtered out, never null

uri - the target URI for the handshake, never null

protocols - requested sub-protocols, or an empty list

extensions - requested WebSocket extensions, or an empty list

handshakeAttributes - attributes to make available via WebSocketSession.getHandshakeAttributes(); currently always an empty map.

Returns:

the established WebSocket session wrapped in a ListenableFuture.