org.cometd.websocket.client

Class JettyWebSocketTransport

java.lang.Object

org.cometd.common.AbstractTransport

org.cometd.client.transport.ClientTransport

org.cometd.client.transport.HttpClientTransport

org.cometd.websocket.client.AbstractWebSocketTransport

org.cometd.websocket.client.JettyWebSocketTransport

All Implemented Interfaces:

org.cometd.bayeux.Transport, org.cometd.client.transport.MessageClientTransport, org.eclipse.jetty.websocket.client.io.UpgradeListener

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

Nested Class Summary

Nested Classes

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

Nested classes/interfaces inherited from class org.cometd.websocket.client.AbstractWebSocketTransport

AbstractWebSocketTransport.Delegate

Field Summary

Fields inherited from class org.cometd.websocket.client.AbstractWebSocketTransport

CONNECT_TIMEOUT_OPTION, IDLE_TIMEOUT_OPTION, MAX_MESSAGE_SIZE_OPTION, NAME, PREFIX, PROTOCOL_OPTION, STICKY_RECONNECT_OPTION

Fields inherited from class org.cometd.client.transport.ClientTransport

JSON_CONTEXT_OPTION, logger, MAX_NETWORK_DELAY_OPTION, SCHEDULER_OPTION

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
boolean	accept(String version)
protected AbstractWebSocketTransport.Delegate	connect(String uri, org.cometd.client.transport.TransportListener listener, List<org.cometd.bayeux.Message.Mutable> messages)
protected AbstractWebSocketTransport.Delegate	connect(org.eclipse.jetty.websocket.client.WebSocketClient client, org.eclipse.jetty.websocket.client.ClientUpgradeRequest request, String uri)
void	init()
protected AbstractWebSocketTransport.Delegate	newDelegate()
void	onHandshakeRequest(org.eclipse.jetty.websocket.api.UpgradeRequest request)
void	onHandshakeResponse(org.eclipse.jetty.websocket.api.UpgradeResponse response)

Methods inherited from class org.cometd.websocket.client.AbstractWebSocketTransport

abort, getConnectTimeout, getDelegate, getIdleTimeout, getProtocol, isStickyReconnect, send, setMessageTransportListener, setURL, storeCookies, terminate

Methods inherited from class org.cometd.client.transport.HttpClientTransport

getCookieStore, getURL, setCookieStore

Methods inherited from class org.cometd.client.transport.ClientTransport

generateJSON, getMaxNetworkDelay, parseMessages, setMaxNetworkDelay

Methods inherited from class org.cometd.common.AbstractTransport

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

Methods inherited from class java.lang.Object

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

Constructor Detail

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 Detail

accept

public boolean accept(String version)

Specified by:

accept in class org.cometd.client.transport.ClientTransport

init

public void init()

Overrides:

init in class AbstractWebSocketTransport

connect

protected AbstractWebSocketTransport.Delegate connect(String uri,
                                                      org.cometd.client.transport.TransportListener listener,
                                                      List<org.cometd.bayeux.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,
                                                      String uri)
                                               throws IOException,
                                                      InterruptedException

Throws:

IOException

InterruptedException

newDelegate

protected AbstractWebSocketTransport.Delegate newDelegate()

onHandshakeRequest

public void onHandshakeRequest(org.eclipse.jetty.websocket.api.UpgradeRequest request)

Specified by:

onHandshakeRequest in interface org.eclipse.jetty.websocket.client.io.UpgradeListener

onHandshakeResponse

public void onHandshakeResponse(org.eclipse.jetty.websocket.api.UpgradeResponse response)

Specified by:

onHandshakeResponse in interface org.eclipse.jetty.websocket.client.io.UpgradeListener