Class JettyWebSocketTransport

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.jetty.JettyWebSocketTransport

All Implemented Interfaces:

Transport, MessageClientTransport, org.eclipse.jetty.websocket.client.JettyUpgradeListener

public class JettyWebSocketTransport
extends AbstractWebSocketTransport
implements org.eclipse.jetty.websocket.client.JettyUpgradeListener

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JettyWebSocketTransport.Factory
class	JettyWebSocketTransport.JettyWebSocketDelegate

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
JettyWebSocketTransport(String url, Map<String,Object> options, ScheduledExecutorService scheduler, org.eclipse.jetty.websocket.client.WebSocketClient webSocketClient)
JettyWebSocketTransport(Map<String,Object> options, ScheduledExecutorService scheduler, org.eclipse.jetty.websocket.client.WebSocketClient webSocketClient)

Method Summary

Modifier and Type	Method	Description
boolean	accept(String version)
protected AbstractWebSocketTransport.Delegate	connect(String uriString, TransportListener listener, List<Message.Mutable> messages)
protected AbstractWebSocketTransport.Delegate	connect(org.eclipse.jetty.websocket.client.WebSocketClient client, org.eclipse.jetty.websocket.client.ClientUpgradeRequest request)
static Map<String, List<String>>	headersToMap(org.eclipse.jetty.http.HttpFields headers)
void	init()
protected AbstractWebSocketTransport.Delegate	newDelegate()
void	onHandshakeRequest(org.eclipse.jetty.client.Request request)
void	onHandshakeResponse(org.eclipse.jetty.client.Request request, org.eclipse.jetty.client.Response 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

JettyWebSocketTransport

public JettyWebSocketTransport(Map<String,Object> options,
 ScheduledExecutorService scheduler,
 org.eclipse.jetty.websocket.client.WebSocketClient webSocketClient)

JettyWebSocketTransport

public JettyWebSocketTransport(String url,
 Map<String,Object> options,
 ScheduledExecutorService scheduler,
 org.eclipse.jetty.websocket.client.WebSocketClient webSocketClient)

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 uriString,
 TransportListener listener,
 List<Message.Mutable> messages)

Specified by:

connect in class AbstractWebSocketTransport

connect

protected AbstractWebSocketTransport.Delegate connect(org.eclipse.jetty.websocket.client.WebSocketClient client,
 org.eclipse.jetty.websocket.client.ClientUpgradeRequest request)
                                               throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

newDelegate

protected AbstractWebSocketTransport.Delegate newDelegate()

onHandshakeRequest

public void onHandshakeRequest(org.eclipse.jetty.client.Request request)

Specified by:

onHandshakeRequest in interface org.eclipse.jetty.websocket.client.JettyUpgradeListener

onHandshakeResponse

public void onHandshakeResponse(org.eclipse.jetty.client.Request request,
 org.eclipse.jetty.client.Response response)

Specified by:

onHandshakeResponse in interface org.eclipse.jetty.websocket.client.JettyUpgradeListener

headersToMap

public static Map<String, List<String>> headersToMap(org.eclipse.jetty.http.HttpFields headers)