Package org.springframework.web.socket.client

Class AbstractWebSocketClient

java.lang.Object
org.springframework.web.socket.client.AbstractWebSocketClient
All Implemented Interfaces:
WebSocketClient
Direct Known Subclasses:
JettyWebSocketClient, StandardWebSocketClient
public abstract class AbstractWebSocketClient extends Object implements WebSocketClient
Abstract base class for WebSocketClient implementations.
Since:
4.0
Author:
Rossen Stoyanchev

  • Field Details

    • logger

      protected final Log logger

  • Constructor Details

    • AbstractWebSocketClient

      public AbstractWebSocketClient()

  • Method Details

    • execute

      public CompletableFuture<WebSocketSession> execute(WebSocketHandler webSocketHandler, String uriTemplate, Object... uriVars)
      Description copied from interface: WebSocketClient
      Execute a handshake request to the given url and handle the resulting WebSocket session with the given handler.
      Specified by:
      execute in interface WebSocketClient
      Parameters:
      webSocketHandler - the session handler
      uriTemplate - the url template
      uriVars - the variables to expand the template
      Returns:
      a future that completes when the session is available

    • execute

      public final CompletableFuture<WebSocketSession> execute(WebSocketHandler webSocketHandler, @Nullable WebSocketHttpHeaders headers, URI uri)
      Description copied from interface: WebSocketClient
      Execute a handshake request to the given url and handle the resulting WebSocket session with the given handler.
      Specified by:
      execute in interface WebSocketClient
      Parameters:
      webSocketHandler - the session handler
      uri - the url
      Returns:
      a future that completes when the session is available

    • assertUri

      protected void assertUri(URI uri)

    • doHandshakeInternal

      @Deprecated protected ListenableFuture<WebSocketSession> doHandshakeInternal(WebSocketHandler webSocketHandler, HttpHeaders headers, URI uri, List<String> subProtocols, List<WebSocketExtension> extensions, Map<String,Object> attributes)
      Deprecated.
      as of 6.0, in favor of executeInternal(WebSocketHandler, HttpHeaders, URI, List, List, Map)
      Perform the actual handshake to establish a connection to the server.
      Parameters:
      webSocketHandler - the client-side handler for WebSocket messages
      headers - the HTTP headers to use for the handshake, with unwanted (forbidden) headers filtered out (never null)
      uri - the target URI for the handshake (never null)
      subProtocols - requested sub-protocols, or an empty list
      extensions - requested WebSocket extensions, or an empty list
      attributes - the attributes to associate with the WebSocketSession, i.e. via WebSocketSession.getAttributes(); currently always an empty map.
      Returns:
      the established WebSocket session wrapped in a ListenableFuture.

    • executeInternal

      protected abstract CompletableFuture<WebSocketSession> executeInternal(WebSocketHandler webSocketHandler, HttpHeaders headers, URI uri, List<String> subProtocols, List<WebSocketExtension> extensions, Map<String,Object> attributes)
      Perform the actual handshake to establish a connection to the server.
      Parameters:
      webSocketHandler - the client-side handler for WebSocket messages
      headers - the HTTP headers to use for the handshake, with unwanted (forbidden) headers filtered out (never null)
      uri - the target URI for the handshake (never null)
      subProtocols - requested sub-protocols, or an empty list
      extensions - requested WebSocket extensions, or an empty list
      attributes - the attributes to associate with the WebSocketSession, i.e. via WebSocketSession.getAttributes(); currently always an empty map
      Returns:
      the established WebSocket session wrapped in a CompletableFuture.