Class JettyWebSocketTransport

java.lang.Object

org.cometd.common.AbstractTransport

org.cometd.server.AbstractServerTransport

org.cometd.server.websocket.common.AbstractWebSocketTransport

org.cometd.server.websocket.jetty.JettyWebSocketTransport

All Implemented Interfaces:

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

public class JettyWebSocketTransport
extends AbstractWebSocketTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	JettyWebSocketTransport.EndPoint

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 inherited from class org.cometd.server.websocket.common.AbstractWebSocketTransport

BUFFER_SIZE_OPTION, COMETD_URL_MAPPING_OPTION, ENABLE_EXTENSION_PREFIX_OPTION, IDLE_TIMEOUT_OPTION, MESSAGES_PER_FRAME_OPTION, NAME, PREFIX, PROTOCOL_OPTION, 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

Constructor	Description
JettyWebSocketTransport(BayeuxServerImpl bayeux)

Method Summary

Modifier and Type	Method	Description
protected boolean	checkOrigin(org.eclipse.jetty.websocket.server.ServerUpgradeRequest request, String origin)
void	init()	Initializes the transport, resolving default and direct options.
protected void	modifyUpgrade(org.eclipse.jetty.websocket.server.ServerUpgradeRequest request, org.eclipse.jetty.websocket.server.ServerUpgradeResponse response)
protected Object	newWebSocketEndPoint(BayeuxContext bayeuxContext)

Methods inherited from class org.cometd.server.websocket.common.AbstractWebSocketTransport

getMessagesPerFrame, getProtocol, isRequireHandshakePerConnection, normalizeURLMapping, onClose, toJSON, writeComplete

Methods inherited from class org.cometd.server.AbstractServerTransport

allowMessageDeliveryDuringHandshake, destroy, dump, getBayeuxServer, getInterval, getJSONContextServer, getMaxInterval, getMaxLazyTimeout, getMaxMessageSize, getTimeout, isAllowMessageDeliveryDuringHandshake, isHandshakeReconnect, isMetaConnectDeliveryOnly, newMetaConnectCycle, 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

Constructor Details

JettyWebSocketTransport

public JettyWebSocketTransport(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 AbstractWebSocketTransport

newWebSocketEndPoint

protected Object newWebSocketEndPoint(BayeuxContext bayeuxContext)

modifyUpgrade

protected void modifyUpgrade(org.eclipse.jetty.websocket.server.ServerUpgradeRequest request,
 org.eclipse.jetty.websocket.server.ServerUpgradeResponse response)

checkOrigin

protected boolean checkOrigin(org.eclipse.jetty.websocket.server.ServerUpgradeRequest request,
 String origin)