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 org.cometd.client.transport.HttpClientTransport

Nested Class Summary

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

org.cometd.client.transport.ClientTransport.Factory, org.cometd.client.transport.ClientTransport.FailureHandler, org.cometd.client.transport.ClientTransport.FailureInfo

Field Summary

Fields

Modifier and Type	Field	Description
static final String	NAME
static final 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	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	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(org.cometd.client.transport.TransportListener listener, List<org.cometd.bayeux.Message.Mutable> requestMessages, String content)
protected void	processResponseMessages(org.cometd.client.transport.TransportListener listener, List<org.cometd.bayeux.Message.Mutable> messages)
protected void	processWrongResponseCode(org.cometd.client.transport.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, getHttpCookieStore, setHttpCookieStore, 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 Object

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

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

PREFIX

public static final String PREFIX

See Also:

• Constant Field Values

Constructor Details

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 Details

accept

public boolean accept(String bayeuxVersion)

Specified by:

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

init

public void init()

Overrides:

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

terminate

public void terminate()

Overrides:

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

abort

public void abort(Throwable failure)

Specified by:

abort in class org.cometd.client.transport.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(org.cometd.client.transport.TransportListener listener,
 List<org.cometd.bayeux.Message.Mutable> requestMessages,
 String content)

processResponseMessages

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

processWrongResponseCode

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