org.cometd.client.http.common

Class AbstractHttpClientTransport

java.lang.Object

org.cometd.common.AbstractTransport

org.cometd.client.transport.ClientTransport

org.cometd.client.transport.HttpClientTransport

org.cometd.client.http.common.AbstractHttpClientTransport

All Implemented Interfaces:

org.cometd.bayeux.Transport

public abstract class AbstractHttpClientTransport
extends HttpClientTransport

Nested Class Summary

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

ClientTransport.Factory, ClientTransport.FailureHandler, ClientTransport.FailureInfo

Field Summary

Fields

Modifier and Type	Field and Description
static String	NAME
static String	PREFIX

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

Modifier	Constructor and Description
protected	AbstractHttpClientTransport(String url, Map<String,Object> options) Deprecated. use AbstractHttpClientTransport(String, Map, ScheduledExecutorService) instead
protected	AbstractHttpClientTransport(String url, Map<String,Object> options, ScheduledExecutorService scheduler)

Method Summary

Modifier and Type	Method and Description
void	abort(Throwable failure)
boolean	accept(String bayeuxVersion)
protected long	calculateMaxNetworkDelay(List<org.cometd.bayeux.Message.Mutable> messages)
protected Map<String,Object>	getAdvice()
int	getMaxMessageSize()
void	init()
protected boolean	isAborted()
protected boolean	isAppendMessageType()
protected String	newRequestURI(List<org.cometd.bayeux.Message.Mutable> messages)
protected void	processResponseContent(TransportListener listener, List<org.cometd.bayeux.Message.Mutable> requestMessages, String content)
protected void	processResponseMessages(TransportListener listener, List<org.cometd.bayeux.Message.Mutable> messages)
protected void	processWrongResponseCode(TransportListener listener, List<org.cometd.bayeux.Message.Mutable> messages, int code)
protected void	setAdvice(Map<String,Object> advice)
void	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, send, setMaxNetworkDelay, setURL, 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

Field Detail

NAME

public static final String NAME

See Also:

Constant Field Values

PREFIX

public static final String PREFIX

See Also:

Constant Field Values

Constructor Detail

AbstractHttpClientTransport

@Deprecated
protected AbstractHttpClientTransport(String url,
                                                  Map<String,Object> options)

Deprecated. use AbstractHttpClientTransport(String, Map, ScheduledExecutorService) instead

Parameters:

url - the CometD server URL

options - the transport options

AbstractHttpClientTransport

protected AbstractHttpClientTransport(String url,
                                      Map<String,Object> options,
                                      ScheduledExecutorService scheduler)

Method Detail

accept

public boolean accept(String bayeuxVersion)

Specified by:

accept in class ClientTransport

init

public void init()

Overrides:

init in class ClientTransport

terminate

public void terminate()

Overrides:

terminate in class ClientTransport

abort

public void abort(Throwable failure)

Specified by:

abort in class ClientTransport

isAborted

protected boolean isAborted()

getMaxMessageSize

public int getMaxMessageSize()

isAppendMessageType

protected boolean isAppendMessageType()

newRequestURI

protected String newRequestURI(List<org.cometd.bayeux.Message.Mutable> messages)

getAdvice

protected Map<String,Object> getAdvice()

setAdvice

protected void setAdvice(Map<String,Object> advice)

calculateMaxNetworkDelay

protected long calculateMaxNetworkDelay(List<org.cometd.bayeux.Message.Mutable> messages)

processResponseContent

protected void processResponseContent(TransportListener listener,
                                      List<org.cometd.bayeux.Message.Mutable> requestMessages,
                                      String content)

processResponseMessages

protected void processResponseMessages(TransportListener listener,
                                       List<org.cometd.bayeux.Message.Mutable> messages)

processWrongResponseCode

protected void processWrongResponseCode(TransportListener listener,
                                        List<org.cometd.bayeux.Message.Mutable> messages,
                                        int code)