org.cometd.websocket.server

Class WebSocketTransport

java.lang.Object

org.cometd.common.AbstractTransport

org.cometd.server.AbstractServerTransport

org.cometd.server.transport.HttpTransport

org.cometd.websocket.server.WebSocketTransport

All Implemented Interfaces:

org.cometd.bayeux.server.ServerTransport, org.cometd.bayeux.Transport, org.eclipse.jetty.websocket.WebSocketFactory.Acceptor

public class WebSocketTransport
extends HttpTransport
implements org.eclipse.jetty.websocket.WebSocketFactory.Acceptor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	WebSocketTransport.WebSocketContext
protected class	WebSocketTransport.WebSocketScheduler

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

AbstractServerTransport.OneTimeScheduler, AbstractServerTransport.Scheduler

Field Summary

Fields

Modifier and Type	Field and Description
static String	BUFFER_SIZE_OPTION
static String	IDLE_TIMEOUT_OPTION
static String	MAX_MESSAGE_SIZE_OPTION
static String	MESSAGES_PER_FRAME_OPTION
static String	NAME
static String	PREFIX
static String	PROTOCOL_OPTION
static String	THREAD_POOL_MAX_SIZE

Fields inherited from class org.cometd.server.transport.HttpTransport

JSON_DEBUG_OPTION, MESSAGE_PARAM

Fields inherited from class org.cometd.server.AbstractServerTransport

_logger, INTERVAL_OPTION, MAX_INTERVAL_OPTION, MAX_LAZY_TIMEOUT_OPTION, MAX_QUEUE_OPTION, META_CONNECT_DELIVERY_OPTION, RANDOMIZE_LAZY_TIMEOUT_OPTION, TIMEOUT_OPTION

Constructor Summary

Constructors

Constructor and Description
WebSocketTransport(BayeuxServerImpl bayeux)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	accept(javax.servlet.http.HttpServletRequest request)
boolean	checkOrigin(javax.servlet.http.HttpServletRequest request, String origin)
protected void	destroy()
org.eclipse.jetty.websocket.WebSocket	doWebSocketConnect(javax.servlet.http.HttpServletRequest request, String protocol)
org.cometd.bayeux.server.BayeuxContext	getContext()
void	handle(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response)
protected void	handleException(org.eclipse.jetty.websocket.WebSocket.Connection connection, Throwable exception)
protected void	handleJSONParseException(org.eclipse.jetty.websocket.WebSocket.Connection connection, String json, Throwable exception)
void	init()
protected Executor	newExecutor()
protected ScheduledExecutorService	newScheduledExecutor()
protected void	onClose(int code, String message)
protected void	send(org.eclipse.jetty.websocket.WebSocket.Connection connection, List<org.cometd.bayeux.server.ServerMessage> messages)
protected void	send(org.eclipse.jetty.websocket.WebSocket.Connection connection, org.cometd.bayeux.server.ServerMessage message)
protected void	send(org.eclipse.jetty.websocket.WebSocket.Connection connection, String data)

Methods inherited from class org.cometd.server.transport.HttpTransport

getCurrentRequest, setCurrentRequest

Methods inherited from class org.cometd.server.AbstractServerTransport

debug, getAdvice, getBayeux, getInterval, getMaxInterval, getMaxLazyTimeout, getTimeout, isMetaConnectDeliveryOnly, parseMessages, parseMessages, setAdvice, setInterval, setMaxInterval, setMaxLazyTimeout, setMetaConnectDeliveryOnly, setTimeout, sweep

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

Methods inherited from interface org.cometd.bayeux.Transport

getName, getOption, getOptionNames, getOptionPrefix

Field Detail

PREFIX

public static final String PREFIX

See Also:

Constant Field Values

NAME

public static final String NAME

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

MAX_MESSAGE_SIZE_OPTION

public static final String MAX_MESSAGE_SIZE_OPTION

See Also:

Constant Field Values

IDLE_TIMEOUT_OPTION

public static final String IDLE_TIMEOUT_OPTION

See Also:

Constant Field Values

THREAD_POOL_MAX_SIZE

public static final String THREAD_POOL_MAX_SIZE

See Also:

Constant Field Values

Constructor Detail

WebSocketTransport

public WebSocketTransport(BayeuxServerImpl bayeux)

Method Detail

init

public void init()

Overrides:

init in class AbstractServerTransport

destroy

protected void destroy()

Overrides:

destroy in class AbstractServerTransport

newExecutor

protected Executor newExecutor()

newScheduledExecutor

protected ScheduledExecutorService newScheduledExecutor()

accept

public boolean accept(javax.servlet.http.HttpServletRequest request)

Specified by:

accept in class HttpTransport

handle

public void handle(javax.servlet.http.HttpServletRequest request,
          javax.servlet.http.HttpServletResponse response)
            throws IOException,
                   javax.servlet.ServletException

Specified by:

handle in class HttpTransport

Throws:

IOException

javax.servlet.ServletException

doWebSocketConnect

public org.eclipse.jetty.websocket.WebSocket doWebSocketConnect(javax.servlet.http.HttpServletRequest request,
                                                       String protocol)

Specified by:

doWebSocketConnect in interface org.eclipse.jetty.websocket.WebSocketFactory.Acceptor

checkOrigin

public boolean checkOrigin(javax.servlet.http.HttpServletRequest request,
                  String origin)

Specified by:

checkOrigin in interface org.eclipse.jetty.websocket.WebSocketFactory.Acceptor

handleJSONParseException

protected void handleJSONParseException(org.eclipse.jetty.websocket.WebSocket.Connection connection,
                            String json,
                            Throwable exception)

handleException

protected void handleException(org.eclipse.jetty.websocket.WebSocket.Connection connection,
                   Throwable exception)

getContext

public org.cometd.bayeux.server.BayeuxContext getContext()

Specified by:

getContext in interface org.cometd.bayeux.server.ServerTransport

Overrides:

getContext in class HttpTransport

send

protected void send(org.eclipse.jetty.websocket.WebSocket.Connection connection,
        List<org.cometd.bayeux.server.ServerMessage> messages)
             throws IOException

Throws:

IOException

send

protected void send(org.eclipse.jetty.websocket.WebSocket.Connection connection,
        org.cometd.bayeux.server.ServerMessage message)
             throws IOException

Throws:

IOException

send

protected void send(org.eclipse.jetty.websocket.WebSocket.Connection connection,
        String data)
             throws IOException

Throws:

IOException

onClose

protected void onClose(int code,
           String message)