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:

Transport

Direct Known Subclasses:

JettyHttpClientTransport, OkHttpClientTransport

public abstract class AbstractHttpClientTransport
extends HttpClientTransport

Nested Class Summary

Nested classes/interfaces inherited from class ClientTransport

ClientTransport.Factory, ClientTransport.FailureHandler, ClientTransport.FailureInfo

Field Summary

Fields

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

Fields inherited from class 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)	Aborts this transport, usually by cancelling all pending Bayeux messages that require a response, such as /meta/connects, without waiting for a response.
boolean	accept(String bayeuxVersion)
protected long	calculateMaxNetworkDelay(List<Message.Mutable> messages)
protected Map<String,Object>	getAdvice()
int	getMaxMessageSize()
void	init()
protected boolean	isAborted()
protected boolean	isAppendMessageType()
protected String	newRequestURI(List<Message.Mutable> messages)
protected void	processResponseContent(TransportListener listener, List<Message.Mutable> requestMessages, String content)
protected void	processResponseMessages(TransportListener listener, List<Message.Mutable> messages)
protected void	processWrongResponseCode(TransportListener listener, List<Message.Mutable> messages, int code)
protected void	setAdvice(Map<String,Object> advice)
void	terminate()	Terminates this transport, usually by closing network connections opened directly by this transport.

Methods inherited from class HttpClientTransport

getCookies, getHttpCookieStore, setHttpCookieStore, storeCookies

Methods inherited from class ClientTransport

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

Methods inherited from class 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 ClientTransport

init

public void init()

Overrides:

init in class ClientTransport

terminate

public void terminate()

Description copied from class: ClientTransport

Terminates this transport, usually by closing network connections opened directly by this transport.

Overrides:

terminate in class ClientTransport

See Also:

• ClientSession.disconnect()

abort

public void abort(Throwable failure)

Description copied from class: ClientTransport

Aborts this transport, usually by cancelling all pending Bayeux messages that require a response, such as /meta/connects, without waiting for a response.

Specified by:

abort in class ClientTransport

Parameters:

failure - the cause of the abort

See Also:

• BayeuxClient.abort()

isAborted

protected boolean isAborted()

getMaxMessageSize

public int getMaxMessageSize()

isAppendMessageType

protected boolean isAppendMessageType()

newRequestURI

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

getAdvice

protected Map<String,Object> getAdvice()

setAdvice

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

calculateMaxNetworkDelay

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

processResponseContent

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

processResponseMessages

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

processWrongResponseCode

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