io.undertow.websockets.jsr

Class ServerWebSocketContainer

java.lang.Object

io.undertow.websockets.jsr.ServerWebSocketContainer

All Implemented Interfaces:

Closeable, AutoCloseable, javax.websocket.server.ServerContainer, javax.websocket.WebSocketContainer

public class ServerWebSocketContainer
extends Object
implements javax.websocket.server.ServerContainer, Closeable

ServerContainer implementation which allows to deploy endpoints for a server.

Author:

Norman Maurer

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_WEB_SOCKET_TIMEOUT_SECONDS
static String	TIMEOUT

Constructor Summary

Constructors

Constructor and Description
ServerWebSocketContainer(ClassIntrospecter classIntrospecter, ClassLoader classLoader, org.xnio.XnioWorker xnioWorker, org.xnio.Pool<ByteBuffer> bufferPool, ThreadSetupAction threadSetupAction, boolean dispatchToWorker)
ServerWebSocketContainer(ClassIntrospecter classIntrospecter, org.xnio.XnioWorker xnioWorker, org.xnio.Pool<ByteBuffer> bufferPool, ThreadSetupAction threadSetupAction, boolean dispatchToWorker, boolean clientMode)

Method Summary

Modifier and Type	Method and Description
void	addEndpoint(Class<?> endpoint)
void	addEndpoint(javax.websocket.server.ServerEndpointConfig endpoint)
void	close()
javax.websocket.Session	connectToServer(Class<?> aClass, URI uri)
javax.websocket.Session	connectToServer(Class<? extends javax.websocket.Endpoint> endpointClass, javax.websocket.ClientEndpointConfig cec, URI path)
javax.websocket.Session	connectToServer(javax.websocket.Endpoint endpointInstance, javax.websocket.ClientEndpointConfig config, URI path)
javax.websocket.Session	connectToServer(Object annotatedEndpointInstance, URI path)
void	deploymentComplete()
org.xnio.Pool<ByteBuffer>	getBufferPool()
List<ConfiguredServerEndpoint>	getConfiguredServerEndpoints()
ServletContextImpl	getContextToAddFilter()
long	getDefaultAsyncSendTimeout()
int	getDefaultMaxBinaryMessageBufferSize()
long	getDefaultMaxSessionIdleTimeout()
int	getDefaultMaxTextMessageBufferSize()
Set<javax.websocket.Extension>	getInstalledExtensions()
org.xnio.XnioWorker	getXnioWorker()
void	invokeEndpointMethod(Executor executor, Runnable invocation) Runs a web socket invocation, setting up the threads and dispatching a thread pool Unfortunately we need to dispatch to a thread pool, because there is a good chance that the endpoint will use blocking IO methods.
void	invokeEndpointMethod(Runnable invocation) Directly invokes an endpoint method, without dispatching to an executor
void	setAsyncSendTimeout(long defaultAsyncSendTimeout)
void	setContextToAddFilter(ServletContextImpl contextToAddFilter)
void	setDefaultMaxBinaryMessageBufferSize(int defaultMaxBinaryMessageBufferSize)
void	setDefaultMaxSessionIdleTimeout(long timeout)
void	setDefaultMaxTextMessageBufferSize(int defaultMaxTextMessageBufferSize)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

TIMEOUT

public static final String TIMEOUT

See Also:

Constant Field Values

DEFAULT_WEB_SOCKET_TIMEOUT_SECONDS

public static final int DEFAULT_WEB_SOCKET_TIMEOUT_SECONDS

See Also:

Constant Field Values

Constructor Detail

ServerWebSocketContainer

public ServerWebSocketContainer(ClassIntrospecter classIntrospecter,
                                org.xnio.XnioWorker xnioWorker,
                                org.xnio.Pool<ByteBuffer> bufferPool,
                                ThreadSetupAction threadSetupAction,
                                boolean dispatchToWorker,
                                boolean clientMode)

ServerWebSocketContainer

public ServerWebSocketContainer(ClassIntrospecter classIntrospecter,
                                ClassLoader classLoader,
                                org.xnio.XnioWorker xnioWorker,
                                org.xnio.Pool<ByteBuffer> bufferPool,
                                ThreadSetupAction threadSetupAction,
                                boolean dispatchToWorker)

Method Detail

getDefaultAsyncSendTimeout

public long getDefaultAsyncSendTimeout()

Specified by:

getDefaultAsyncSendTimeout in interface javax.websocket.WebSocketContainer

setAsyncSendTimeout

public void setAsyncSendTimeout(long defaultAsyncSendTimeout)

Specified by:

setAsyncSendTimeout in interface javax.websocket.WebSocketContainer

connectToServer

public javax.websocket.Session connectToServer(Object annotatedEndpointInstance,
                                               URI path)
                                        throws javax.websocket.DeploymentException,
                                               IOException

Specified by:

connectToServer in interface javax.websocket.WebSocketContainer

Throws:

javax.websocket.DeploymentException

IOException

connectToServer

public javax.websocket.Session connectToServer(Class<?> aClass,
                                               URI uri)
                                        throws javax.websocket.DeploymentException,
                                               IOException

Specified by:

connectToServer in interface javax.websocket.WebSocketContainer

Throws:

javax.websocket.DeploymentException

IOException

connectToServer

public javax.websocket.Session connectToServer(javax.websocket.Endpoint endpointInstance,
                                               javax.websocket.ClientEndpointConfig config,
                                               URI path)
                                        throws javax.websocket.DeploymentException,
                                               IOException

Specified by:

connectToServer in interface javax.websocket.WebSocketContainer

Throws:

javax.websocket.DeploymentException

IOException

connectToServer

public javax.websocket.Session connectToServer(Class<? extends javax.websocket.Endpoint> endpointClass,
                                               javax.websocket.ClientEndpointConfig cec,
                                               URI path)
                                        throws javax.websocket.DeploymentException,
                                               IOException

Specified by:

connectToServer in interface javax.websocket.WebSocketContainer

Throws:

javax.websocket.DeploymentException

IOException

getDefaultMaxSessionIdleTimeout

public long getDefaultMaxSessionIdleTimeout()

Specified by:

getDefaultMaxSessionIdleTimeout in interface javax.websocket.WebSocketContainer

setDefaultMaxSessionIdleTimeout

public void setDefaultMaxSessionIdleTimeout(long timeout)

Specified by:

setDefaultMaxSessionIdleTimeout in interface javax.websocket.WebSocketContainer

getDefaultMaxBinaryMessageBufferSize

public int getDefaultMaxBinaryMessageBufferSize()

Specified by:

getDefaultMaxBinaryMessageBufferSize in interface javax.websocket.WebSocketContainer

setDefaultMaxBinaryMessageBufferSize

public void setDefaultMaxBinaryMessageBufferSize(int defaultMaxBinaryMessageBufferSize)

Specified by:

setDefaultMaxBinaryMessageBufferSize in interface javax.websocket.WebSocketContainer

getDefaultMaxTextMessageBufferSize

public int getDefaultMaxTextMessageBufferSize()

Specified by:

getDefaultMaxTextMessageBufferSize in interface javax.websocket.WebSocketContainer

setDefaultMaxTextMessageBufferSize

public void setDefaultMaxTextMessageBufferSize(int defaultMaxTextMessageBufferSize)

Specified by:

setDefaultMaxTextMessageBufferSize in interface javax.websocket.WebSocketContainer

getInstalledExtensions

public Set<javax.websocket.Extension> getInstalledExtensions()

Specified by:

getInstalledExtensions in interface javax.websocket.WebSocketContainer

invokeEndpointMethod

public void invokeEndpointMethod(Executor executor,
                                 Runnable invocation)

Runs a web socket invocation, setting up the threads and dispatching a thread pool

Unfortunately we need to dispatch to a thread pool, because there is a good chance that the endpoint will use blocking IO methods. We suspend recieves while this is in progress, to make sure that we do not have multiple methods invoked at once.

Parameters:

invocation - The task to run

invokeEndpointMethod

public void invokeEndpointMethod(Runnable invocation)

Directly invokes an endpoint method, without dispatching to an executor

Parameters:

invocation - The invocation

addEndpoint

public void addEndpoint(Class<?> endpoint)
                 throws javax.websocket.DeploymentException

Specified by:

addEndpoint in interface javax.websocket.server.ServerContainer

Throws:

javax.websocket.DeploymentException

addEndpoint

public void addEndpoint(javax.websocket.server.ServerEndpointConfig endpoint)
                 throws javax.websocket.DeploymentException

Specified by:

addEndpoint in interface javax.websocket.server.ServerContainer

Throws:

javax.websocket.DeploymentException

deploymentComplete

public void deploymentComplete()

getConfiguredServerEndpoints

public List<ConfiguredServerEndpoint> getConfiguredServerEndpoints()

getContextToAddFilter

public ServletContextImpl getContextToAddFilter()

setContextToAddFilter

public void setContextToAddFilter(ServletContextImpl contextToAddFilter)

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

getBufferPool

public org.xnio.Pool<ByteBuffer> getBufferPool()

getXnioWorker

public org.xnio.XnioWorker getXnioWorker()