org.cometd.client.websocket.okhttp

Class OkHttpWebSocketTransport

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.okhttp.OkHttpWebSocketTransport

All Implemented Interfaces:

Transport, MessageClientTransport

public class OkHttpWebSocketTransport
extends AbstractWebSocketTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OkHttpWebSocketTransport.Factory
protected class	OkHttpWebSocketTransport.OkHttpDelegate

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

AbstractWebSocketTransport.Delegate

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

ClientTransport.FailureHandler, ClientTransport.FailureInfo

Field Summary

Fields inherited from class org.cometd.client.websocket.common.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 org.cometd.client.transport.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 and Description
OkHttpWebSocketTransport(Map<String,Object> options, okhttp3.OkHttpClient okHttpClient)
OkHttpWebSocketTransport(String uri, Map<String,Object> options, ScheduledExecutorService scheduler, okhttp3.OkHttpClient okHttpClient)

Method Summary

Modifier and Type	Method and Description
boolean	accept(String s)
protected AbstractWebSocketTransport.Delegate	connect(String uri, TransportListener listener, List<Message.Mutable> messages)
static Map<String,List<String>>	headersToMap(okhttp3.Headers headers)
void	init()
protected OkHttpWebSocketTransport.OkHttpDelegate	newDelegate()
protected void	onHandshakeRequest(String uri, okhttp3.Request.Builder upgradeRequest)
protected void	onHandshakeResponse(okhttp3.Response response)

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

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

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

getCookies, getCookieStore, setCookieStore, storeCookies

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

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

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

OkHttpWebSocketTransport

public OkHttpWebSocketTransport(Map<String,Object> options,
                                okhttp3.OkHttpClient okHttpClient)

OkHttpWebSocketTransport

public OkHttpWebSocketTransport(String uri,
                                Map<String,Object> options,
                                ScheduledExecutorService scheduler,
                                okhttp3.OkHttpClient okHttpClient)

Method Detail

init

public void init()

Overrides:

init in class AbstractWebSocketTransport

accept

public boolean accept(String s)

Specified by:

accept in class ClientTransport

connect

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

Specified by:

connect in class AbstractWebSocketTransport

newDelegate

protected OkHttpWebSocketTransport.OkHttpDelegate newDelegate()

onHandshakeRequest

protected void onHandshakeRequest(String uri,
                                  okhttp3.Request.Builder upgradeRequest)

onHandshakeResponse

protected void onHandshakeResponse(okhttp3.Response response)

headersToMap

public static Map<String,List<String>> headersToMap(okhttp3.Headers headers)