Class JdkWebsocketConnector

java.lang.Object

io.fluxzero.sdk.common.websocket.JdkWebsocketConnector

All Implemented Interfaces:

WebsocketConnector

public class JdkWebsocketConnector
extends Object
implements WebsocketConnector

Low-level Fluxzero websocket connector backed by the JDK HttpClient websocket implementation.

The JDK WebSocket API does not expose successful 101 Switching Protocols response headers directly. This connector captures them through a shared CookieHandler wrapper while preserving any cookie handler configured on the supplied HttpClient.

Constructor Summary

Constructors

Constructor	Description
JdkWebsocketConnector()	Creates a connector backed by a default HTTP/1.1 HttpClient.
JdkWebsocketConnector(HttpClient httpClient)	Creates a connector backed by the supplied HTTP client.
JdkWebsocketConnector(HttpClient httpClient, Executor executor)	Creates a connector backed by the supplied HTTP client and executor.

Method Summary

Modifier and Type	Method	Description
WebsocketSession	connect(WebsocketEndpoint endpoint, WebsocketConnectionOptions options, URI uri)	Opens a native JDK WebSocket and adapts it to Fluxzero's low-level WebsocketSession contract.

Methods inherited from class Object

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

Constructor Details

JdkWebsocketConnector

public JdkWebsocketConnector()

Creates a connector backed by a default HTTP/1.1 HttpClient. SDK runtime messages use a separate shared executor from native WebSocket callbacks.

JdkWebsocketConnector

public JdkWebsocketConnector(HttpClient httpClient)

Creates a connector backed by the supplied HTTP client.

A single internal client is derived from this client so the connector can install its handshake-header capturing cookie handler without mutating the original client. Its resolved executor is retained for both native callbacks and SDK runtime messages.

Parameters:

httpClient - base client whose proxy, SSL, authenticator, executor, cookie, and timeout settings are reused

JdkWebsocketConnector

public JdkWebsocketConnector(HttpClient httpClient,
 Executor executor)

Creates a connector backed by the supplied HTTP client and executor.

The executor is used for the internal HTTP client derived from the supplied client, native JDK WebSocket listener callbacks, and SDK runtime messages.

Parameters:

httpClient - base client whose proxy, SSL, authenticator, cookie, and timeout settings are reused

executor - executor for JDK websocket and listener callback work

Method Details

connect

public WebsocketSession connect(WebsocketEndpoint endpoint,
 WebsocketConnectionOptions options,
 URI uri)
                         throws IOException

Opens a native JDK WebSocket and adapts it to Fluxzero's low-level WebsocketSession contract.

Specified by:

connect in interface WebsocketConnector

Parameters:

endpoint - endpoint callbacks for the new session

options - connection options; implementations may accept null as default options

uri - target WebSocket URI

Returns:

an open WebSocket session

Throws:

IOException