Class ClientTransport

java.lang.Object

org.cometd.common.AbstractTransport

org.cometd.client.transport.ClientTransport

All Implemented Interfaces:

Transport

Direct Known Subclasses:

HttpClientTransport

public abstract class ClientTransport
extends AbstractTransport

ClientTransports are used by BayeuxClient to send and receive Bayeux messages.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ClientTransport.Factory
static interface	ClientTransport.FailureHandler
static class	ClientTransport.FailureInfo

Field Summary

Fields

Modifier and Type	Field	Description
static final String	JSON_CONTEXT_OPTION
static final String	MAX_MESSAGE_SIZE_OPTION
static final String	MAX_NETWORK_DELAY_OPTION
static final String	MAX_SEND_BAYEUX_MESSAGE_SIZE_OPTION
static final String	SCHEDULER_OPTION
static final String	URL_OPTION

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ClientTransport(String name, String url, Map<String,Object> options)	Deprecated.
protected	ClientTransport(String name, String url, Map<String,Object> options, ScheduledExecutorService scheduler)

Method Summary

Modifier and Type	Method	Description
abstract 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.
abstract boolean	accept(String version)
protected String	generateJSON(List<Message.Mutable> messages)
protected JSONContext.Client	getJSONContextClient()
long	getMaxNetworkDelay()
protected ScheduledExecutorService	getScheduler()
String	getURL()
void	init()
protected void	initScheduler()
protected List<Message.Mutable>	parseMessages(String content)
abstract void	send(TransportListener listener, List<Message.Mutable> messages)
protected void	setMaxNetworkDelay(long maxNetworkDelay)
void	setURL(String url)
protected void	shutdownScheduler()
void	terminate()	Terminates this transport, usually by closing network connections opened directly by this transport.

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 Details

URL_OPTION

public static final String URL_OPTION

See Also:

• Constant Field Values

MAX_NETWORK_DELAY_OPTION

public static final String MAX_NETWORK_DELAY_OPTION

See Also:

• Constant Field Values

JSON_CONTEXT_OPTION

public static final String JSON_CONTEXT_OPTION

See Also:

• Constant Field Values

SCHEDULER_OPTION

public static final String SCHEDULER_OPTION

See Also:

• Constant Field Values

MAX_SEND_BAYEUX_MESSAGE_SIZE_OPTION

public static final String MAX_SEND_BAYEUX_MESSAGE_SIZE_OPTION

See Also:

• Constant Field Values

MAX_MESSAGE_SIZE_OPTION

public static final String MAX_MESSAGE_SIZE_OPTION

See Also:

• Constant Field Values

Constructor Details

ClientTransport

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

Deprecated.

ClientTransport

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

Method Details

getURL

public String getURL()

setURL

public void setURL(String url)

init

public void init()

getJSONContextClient

protected JSONContext.Client getJSONContextClient()

initScheduler

protected void initScheduler()

shutdownScheduler

protected void shutdownScheduler()

getScheduler

protected ScheduledExecutorService getScheduler()

abort

public abstract 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.

Parameters:

failure - the cause of the abort

See Also:

• BayeuxClient.abort()

terminate

public void terminate()

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

See Also:

• ClientSession.disconnect()

accept

public abstract boolean accept(String version)

send

public abstract void send(TransportListener listener,
 List<Message.Mutable> messages)

parseMessages

protected List<Message.Mutable> parseMessages(String content)
                                       throws ParseException

Throws:

ParseException

generateJSON

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

getMaxNetworkDelay

public long getMaxNetworkDelay()

setMaxNetworkDelay

protected void setMaxNetworkDelay(long maxNetworkDelay)