Class WebSocketTransport

java.lang.Object

org.cometd.common.AbstractTransport

org.cometd.client.transport.ClientTransport

org.cometd.client.transport.HttpClientTransport

org.cometd.client.websocket.common.AbstractWebSocketTransport

org.cometd.client.websocket.jakarta.WebSocketTransport

All Implemented Interfaces:

Transport, MessageClientTransport

public class WebSocketTransport
extends AbstractWebSocketTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	WebSocketTransport.Factory
class	WebSocketTransport.WebSocketDelegate

Nested classes/interfaces inherited from class AbstractWebSocketTransport

AbstractWebSocketTransport.Delegate

Nested classes/interfaces inherited from class ClientTransport

ClientTransport.FailureHandler, ClientTransport.FailureInfo

Field Summary

Fields inherited from class AbstractWebSocketTransport

CONNECT_TIMEOUT_OPTION, COOKIE_HEADER, IDLE_TIMEOUT_OPTION, MAX_CLOSE_REASON_LENGTH, NAME, NORMAL_CLOSE_CODE, PERMESSAGE_DEFLATE_OPTION, PREFIX, PROTOCOL_OPTION, STICKY_RECONNECT_OPTION

Fields inherited from class ClientTransport

JSON_CONTEXT_OPTION, MAX_MESSAGE_SIZE_OPTION, MAX_NETWORK_DELAY_OPTION, MAX_SEND_BAYEUX_MESSAGE_SIZE_OPTION, SCHEDULER_OPTION, URL_OPTION

Constructor Summary

Constructors

Constructor	Description
WebSocketTransport(String url, Map<String,Object> options, ScheduledExecutorService scheduler, jakarta.websocket.WebSocketContainer webSocketContainer)
WebSocketTransport(Map<String,Object> options, ScheduledExecutorService scheduler, jakarta.websocket.WebSocketContainer webSocketContainer)

Method Summary

Modifier and Type	Method	Description
boolean	accept(String version)
protected AbstractWebSocketTransport.Delegate	connect(jakarta.websocket.WebSocketContainer container, jakarta.websocket.ClientEndpointConfig configuration, String uri)
protected AbstractWebSocketTransport.Delegate	connect(String uri, TransportListener listener, List<Message.Mutable> messages)
void	init()
protected WebSocketTransport.WebSocketDelegate	newDelegate()
protected void	onHandshakeRequest(Map<String, List<String>> headers)
protected void	onHandshakeResponse(jakarta.websocket.HandshakeResponse response)

Methods inherited from class AbstractWebSocketTransport

abort, getConnectTimeout, getDelegate, getIdleTimeout, getProtocol, isPerMessageDeflateEnabled, isStickyReconnect, locked, locked, send, setMessageTransportListener, setURL, terminate

Methods inherited from class HttpClientTransport

getCookies, getHttpCookieStore, setHttpCookieStore, storeCookies

Methods inherited from class ClientTransport

generateJSON, getJSONContextClient, getMaxNetworkDelay, getScheduler, getURL, initScheduler, parseMessages, setMaxNetworkDelay, shutdownScheduler

Methods inherited from class AbstractTransport

getName, getOption, getOption, getOption, getOption, getOption, getOptionNames, getOptionPrefix, setOption, setOptionPrefix

Methods inherited from class Object

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

Constructor Details

WebSocketTransport

public WebSocketTransport(Map<String,Object> options,
 ScheduledExecutorService scheduler,
 jakarta.websocket.WebSocketContainer webSocketContainer)

WebSocketTransport

public WebSocketTransport(String url,
 Map<String,Object> options,
 ScheduledExecutorService scheduler,
 jakarta.websocket.WebSocketContainer webSocketContainer)

Method Details

accept

public boolean accept(String version)

Specified by:

accept in class ClientTransport

init

public void init()

Overrides:

init in class AbstractWebSocketTransport

connect

protected AbstractWebSocketTransport.Delegate connect(String uri,
 TransportListener listener,
 List<Message.Mutable> messages)

Specified by:

connect in class AbstractWebSocketTransport

connect

protected AbstractWebSocketTransport.Delegate connect(jakarta.websocket.WebSocketContainer container,
 jakarta.websocket.ClientEndpointConfig configuration,
 String uri)
                                               throws IOException

Throws:

IOException

newDelegate

protected WebSocketTransport.WebSocketDelegate newDelegate()

onHandshakeRequest

protected void onHandshakeRequest(Map<String, List<String>> headers)

onHandshakeResponse

protected void onHandshakeResponse(jakarta.websocket.HandshakeResponse response)