Package org.cometd.server.websocket.common

Class AbstractWebSocketTransport

java.lang.Object

org.cometd.common.AbstractTransport

org.cometd.server.AbstractServerTransport

org.cometd.server.websocket.common.AbstractWebSocketTransport

All Implemented Interfaces:

ServerTransport, Transport, org.eclipse.jetty.util.component.Dumpable

Direct Known Subclasses:

JettyWebSocketTransport, WebSocketTransport

public abstract class AbstractWebSocketTransport
extends AbstractServerTransport

Nested Class Summary

Nested classes/interfaces inherited from class org.cometd.server.AbstractServerTransport

AbstractServerTransport.Scheduler

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.Dumpable

org.eclipse.jetty.util.component.Dumpable.DumpableContainer

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BUFFER_SIZE_OPTION
static final String	COMETD_URL_MAPPING_OPTION
static final String	ENABLE_EXTENSION_PREFIX_OPTION
static final String	IDLE_TIMEOUT_OPTION
static final String	MESSAGES_PER_FRAME_OPTION
static final String	NAME
static final String	PREFIX
static final String	PROTOCOL_OPTION
static final String	REQUIRE_HANDSHAKE_PER_CONNECTION_OPTION

Fields inherited from class org.cometd.server.AbstractServerTransport

ALLOW_MESSAGE_DELIVERY_DURING_HANDSHAKE, HANDSHAKE_RECONNECT_OPTION, INTERVAL_OPTION, JSON_CONTEXT_OPTION, MAX_INTERVAL_OPTION, MAX_LAZY_TIMEOUT_OPTION, MAX_MESSAGE_SIZE_OPTION, MAX_PROCESSING_OPTION, MAX_QUEUE_OPTION, META_CONNECT_DELIVERY_OPTION, TIMEOUT_OPTION

Fields inherited from interface org.eclipse.jetty.util.component.Dumpable

KEY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractWebSocketTransport(BayeuxServerImpl bayeux)

Method Summary

Modifier and Type	Method	Description
int	getMessagesPerFrame()
String	getProtocol()
void	init()	Initializes the transport, resolving default and direct options.
boolean	isRequireHandshakePerConnection()
protected List<String>	normalizeURLMapping(String urlMapping)
protected void	onClose(int code, String reason)
protected String	toJSON(ServerMessage message)
protected void	writeComplete(AbstractWebSocketEndPoint.Context context, List<ServerMessage> messages)

Methods inherited from class org.cometd.server.AbstractServerTransport

allowMessageDeliveryDuringHandshake, destroy, dump, getBayeux, getInterval, getJSONContextServer, getMaxInterval, getMaxLazyTimeout, getMaxMessageSize, getTimeout, isAllowMessageDeliveryDuringHandshake, isHandshakeReconnect, isMetaConnectDeliveryOnly, newMetaConnectCycle, parseMessages, parseMessages, processReply, scheduleExpiration, setAllowMessageDeliveryDuringHandshake, setHandshakeReconnect, setInterval, setMaxInterval, setMaxLazyTimeout, setMaxMessageSize, setMetaConnectDeliveryOnly, setTimeout, sweep, toString

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, wait, wait, wait

Methods inherited from interface org.eclipse.jetty.util.component.Dumpable

dump, dumpSelf

Methods inherited from interface org.cometd.bayeux.Transport

getName, getOption, getOptionNames, getOptionPrefix

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

PREFIX

public static final String PREFIX

See Also:

• Constant Field Values

PROTOCOL_OPTION

public static final String PROTOCOL_OPTION

See Also:

• Constant Field Values

MESSAGES_PER_FRAME_OPTION

public static final String MESSAGES_PER_FRAME_OPTION

See Also:

• Constant Field Values

BUFFER_SIZE_OPTION

public static final String BUFFER_SIZE_OPTION

See Also:

• Constant Field Values

IDLE_TIMEOUT_OPTION

public static final String IDLE_TIMEOUT_OPTION

See Also:

• Constant Field Values

COMETD_URL_MAPPING_OPTION

public static final String COMETD_URL_MAPPING_OPTION

See Also:

• Constant Field Values

REQUIRE_HANDSHAKE_PER_CONNECTION_OPTION

public static final String REQUIRE_HANDSHAKE_PER_CONNECTION_OPTION

See Also:

• Constant Field Values

ENABLE_EXTENSION_PREFIX_OPTION

public static final String ENABLE_EXTENSION_PREFIX_OPTION

See Also:

• Constant Field Values

Constructor Details

AbstractWebSocketTransport

protected AbstractWebSocketTransport(BayeuxServerImpl bayeux)

Method Details

init

public void init()

Description copied from class: AbstractServerTransport

Initializes the transport, resolving default and direct options.

Overrides:

init in class AbstractServerTransport

getProtocol

public String getProtocol()

getMessagesPerFrame

public int getMessagesPerFrame()

isRequireHandshakePerConnection

public boolean isRequireHandshakePerConnection()

normalizeURLMapping

protected List<String> normalizeURLMapping(String urlMapping)

onClose

protected void onClose(int code,
 String reason)

toJSON

protected String toJSON(ServerMessage message)

Overrides:

toJSON in class AbstractServerTransport

writeComplete

protected void writeComplete(AbstractWebSocketEndPoint.Context context,
 List<ServerMessage> messages)