org.cometd.websocket.client

Class WebSocketTransport

java.lang.Object

org.cometd.common.AbstractTransport

org.cometd.client.transport.ClientTransport

org.cometd.client.transport.HttpClientTransport

org.cometd.websocket.client.WebSocketTransport

All Implemented Interfaces:

org.cometd.bayeux.Transport, MessageClientTransport

public class WebSocketTransport
extends HttpClientTransport
implements MessageClientTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	WebSocketTransport.CometDWebSocket

Nested classes/interfaces inherited from class org.cometd.client.transport.HttpClientTransport

HttpClientTransport.Cookie, HttpClientTransport.CookieProvider, HttpClientTransport.StandardCookieProvider

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONNECT_TIMEOUT_OPTION
static String	IDLE_TIMEOUT_OPTION
static String	MAX_MESSAGE_SIZE_OPTION
static String	NAME
static String	PREFIX
static String	PROTOCOL_OPTION
static String	STICKY_RECONNECT_OPTION

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

INTERVAL_OPTION, JSON_CONTEXT, logger, MAX_NETWORK_DELAY_OPTION, TIMEOUT_OPTION

Constructor Summary

Constructors

Constructor and Description
WebSocketTransport(Map<String,Object> options, org.eclipse.jetty.websocket.WebSocketClientFactory webSocketClientFactory, ScheduledExecutorService scheduler)
WebSocketTransport(String url, Map<String,Object> options, org.eclipse.jetty.websocket.WebSocketClientFactory webSocketClientFactory, ScheduledExecutorService scheduler)

Method Summary

Methods

Modifier and Type	Method and Description
void	abort()
boolean	accept(String version)
protected org.eclipse.jetty.websocket.WebSocket.Connection	connect(org.eclipse.jetty.websocket.WebSocketClient client, URI uri)
static WebSocketTransport	create(Map<String,Object> options, org.eclipse.jetty.websocket.WebSocketClientFactory webSocketClientFactory)
static WebSocketTransport	create(Map<String,Object> options, org.eclipse.jetty.websocket.WebSocketClientFactory webSocketClientFactory, ScheduledExecutorService scheduler)
protected void	disconnect(String reason)
void	init()
protected org.eclipse.jetty.websocket.WebSocketClient	newWebSocketClient()
protected void	onMessages(List<org.cometd.bayeux.Message.Mutable> messages)
void	send(TransportListener listener, org.cometd.bayeux.Message.Mutable... messages)
void	setMessageTransportListener(TransportListener listener)
void	terminate()

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

getCookie, getCookieProvider, getURL, setCookie, setCookieProvider, setURL

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

debug, generateJSON, isDebugEnabled, parseMessages, setDebugEnabled

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

Field Detail

PREFIX

public static final String PREFIX

See Also:

Constant Field Values

NAME

public static final String NAME

See Also:

Constant Field Values

PROTOCOL_OPTION

public static final String PROTOCOL_OPTION

See Also:

Constant Field Values

CONNECT_TIMEOUT_OPTION

public static final String CONNECT_TIMEOUT_OPTION

See Also:

Constant Field Values

IDLE_TIMEOUT_OPTION

public static final String IDLE_TIMEOUT_OPTION

See Also:

Constant Field Values

MAX_MESSAGE_SIZE_OPTION

public static final String MAX_MESSAGE_SIZE_OPTION

See Also:

Constant Field Values

STICKY_RECONNECT_OPTION

public static final String STICKY_RECONNECT_OPTION

See Also:

Constant Field Values

Constructor Detail

WebSocketTransport

public WebSocketTransport(Map<String,Object> options,
                  org.eclipse.jetty.websocket.WebSocketClientFactory webSocketClientFactory,
                  ScheduledExecutorService scheduler)

WebSocketTransport

public WebSocketTransport(String url,
                  Map<String,Object> options,
                  org.eclipse.jetty.websocket.WebSocketClientFactory webSocketClientFactory,
                  ScheduledExecutorService scheduler)

Method Detail

create

public static WebSocketTransport create(Map<String,Object> options,
                        org.eclipse.jetty.websocket.WebSocketClientFactory webSocketClientFactory)

create

public static WebSocketTransport create(Map<String,Object> options,
                        org.eclipse.jetty.websocket.WebSocketClientFactory webSocketClientFactory,
                        ScheduledExecutorService scheduler)

setMessageTransportListener

public void setMessageTransportListener(TransportListener listener)

Specified by:

setMessageTransportListener in interface MessageClientTransport

accept

public boolean accept(String version)

Specified by:

accept in class ClientTransport

init

public void init()

Overrides:

init in class ClientTransport

abort

public void abort()

Specified by:

abort in class ClientTransport

terminate

public void terminate()

Overrides:

terminate in class ClientTransport

disconnect

protected void disconnect(String reason)

send

public void send(TransportListener listener,
        org.cometd.bayeux.Message.Mutable... messages)

Specified by:

send in class ClientTransport

connect

protected org.eclipse.jetty.websocket.WebSocket.Connection connect(org.eclipse.jetty.websocket.WebSocketClient client,
                                                       URI uri)
                                                            throws IOException,
                                                                   InterruptedException,
                                                                   TimeoutException

Throws:

IOException

InterruptedException

TimeoutException

newWebSocketClient

protected org.eclipse.jetty.websocket.WebSocketClient newWebSocketClient()

onMessages

protected void onMessages(List<org.cometd.bayeux.Message.Mutable> messages)