Package io.undertow.websockets.jsr
Class ServerWebSocketContainer
- java.lang.Object
-
- io.undertow.websockets.jsr.ServerWebSocketContainer
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,javax.websocket.server.ServerContainer
,javax.websocket.WebSocketContainer
public class ServerWebSocketContainer extends java.lang.Object implements javax.websocket.server.ServerContainer, java.io.Closeable
ServerContainer
implementation which allows to deploy endpoints for a server.- Author:
- Norman Maurer
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
ServerWebSocketContainer.PauseListener
-
Field Summary
Fields Modifier and Type Field Description static int
DEFAULT_WEB_SOCKET_TIMEOUT_SECONDS
static java.lang.String
TIMEOUT
-
Constructor Summary
Constructors Constructor Description ServerWebSocketContainer(io.undertow.servlet.api.ClassIntrospecter classIntrospecter, java.lang.ClassLoader classLoader, org.xnio.XnioWorker xnioWorker, io.undertow.connector.ByteBufferPool bufferPool, java.util.List<io.undertow.servlet.api.ThreadSetupHandler> threadSetupHandlers, boolean dispatchToWorker)
ServerWebSocketContainer(io.undertow.servlet.api.ClassIntrospecter classIntrospecter, java.lang.ClassLoader classLoader, org.xnio.XnioWorker xnioWorker, io.undertow.connector.ByteBufferPool bufferPool, java.util.List<io.undertow.servlet.api.ThreadSetupHandler> threadSetupHandlers, boolean dispatchToWorker, java.net.InetSocketAddress clientBindAddress, WebSocketReconnectHandler reconnectHandler)
ServerWebSocketContainer(io.undertow.servlet.api.ClassIntrospecter classIntrospecter, java.lang.ClassLoader classLoader, org.xnio.XnioWorker xnioWorker, io.undertow.connector.ByteBufferPool bufferPool, java.util.List<io.undertow.servlet.api.ThreadSetupHandler> threadSetupHandlers, boolean dispatchToWorker, java.net.InetSocketAddress clientBindAddress, WebSocketReconnectHandler reconnectHandler, java.util.List<javax.websocket.Extension> installedExtensions)
ServerWebSocketContainer(io.undertow.servlet.api.ClassIntrospecter classIntrospecter, org.xnio.XnioWorker xnioWorker, io.undertow.connector.ByteBufferPool bufferPool, java.util.List<io.undertow.servlet.api.ThreadSetupHandler> threadSetupHandlers, boolean dispatchToWorker, boolean clientMode)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addEndpoint(java.lang.Class<?> endpoint)
void
addEndpoint(javax.websocket.server.ServerEndpointConfig endpoint)
void
close()
void
close(int waitTime)
javax.websocket.Session
connectToServer(java.lang.Class<?> aClass, io.undertow.websockets.client.WebSocketClient.ConnectionBuilder connectionBuilder)
javax.websocket.Session
connectToServer(java.lang.Class<?> aClass, java.net.URI uri)
javax.websocket.Session
connectToServer(java.lang.Class<? extends javax.websocket.Endpoint> endpointClass, javax.websocket.ClientEndpointConfig cec, java.net.URI path)
javax.websocket.Session
connectToServer(java.lang.Object annotatedEndpointInstance, io.undertow.websockets.client.WebSocketClient.ConnectionBuilder connectionBuilder)
javax.websocket.Session
connectToServer(java.lang.Object annotatedEndpointInstance, java.net.URI path)
javax.websocket.Session
connectToServer(javax.websocket.Endpoint endpointInstance, javax.websocket.ClientEndpointConfig config, io.undertow.websockets.client.WebSocketClient.ConnectionBuilder connectionBuilder)
javax.websocket.Session
connectToServer(javax.websocket.Endpoint endpointInstance, javax.websocket.ClientEndpointConfig config, java.net.URI path)
void
deploymentComplete()
void
doUpgrade(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, javax.websocket.server.ServerEndpointConfig sec, java.util.Map<java.lang.String,java.lang.String> pathParams)
io.undertow.connector.ByteBufferPool
getBufferPool()
java.util.List<ConfiguredServerEndpoint>
getConfiguredServerEndpoints()
io.undertow.servlet.spec.ServletContextImpl
getContextToAddFilter()
long
getDefaultAsyncSendTimeout()
int
getDefaultMaxBinaryMessageBufferSize()
long
getDefaultMaxSessionIdleTimeout()
int
getDefaultMaxTextMessageBufferSize()
java.util.Set<javax.websocket.Extension>
getInstalledExtensions()
WebSocketReconnectHandler
getWebSocketReconnectHandler()
org.xnio.XnioWorker
getXnioWorker()
void
invokeEndpointMethod(java.lang.Runnable invocation)
Directly invokes an endpoint method, without dispatching to an executorvoid
invokeEndpointMethod(java.util.concurrent.Executor executor, java.lang.Runnable invocation)
Runs a web socket invocation, setting up the threads and dispatching a thread poolboolean
isClosed()
boolean
isDispatchToWorker()
void
pause(ServerWebSocketContainer.PauseListener listener)
Pauses the containervoid
resume()
resumes a paused containervoid
setAsyncSendTimeout(long defaultAsyncSendTimeout)
void
setContextToAddFilter(io.undertow.servlet.spec.ServletContextImpl contextToAddFilter)
void
setDefaultMaxBinaryMessageBufferSize(int defaultMaxBinaryMessageBufferSize)
void
setDefaultMaxSessionIdleTimeout(long timeout)
void
setDefaultMaxTextMessageBufferSize(int defaultMaxTextMessageBufferSize)
-
-
-
Field Detail
-
TIMEOUT
public static final java.lang.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(io.undertow.servlet.api.ClassIntrospecter classIntrospecter, org.xnio.XnioWorker xnioWorker, io.undertow.connector.ByteBufferPool bufferPool, java.util.List<io.undertow.servlet.api.ThreadSetupHandler> threadSetupHandlers, boolean dispatchToWorker, boolean clientMode)
-
ServerWebSocketContainer
public ServerWebSocketContainer(io.undertow.servlet.api.ClassIntrospecter classIntrospecter, java.lang.ClassLoader classLoader, org.xnio.XnioWorker xnioWorker, io.undertow.connector.ByteBufferPool bufferPool, java.util.List<io.undertow.servlet.api.ThreadSetupHandler> threadSetupHandlers, boolean dispatchToWorker)
-
ServerWebSocketContainer
public ServerWebSocketContainer(io.undertow.servlet.api.ClassIntrospecter classIntrospecter, java.lang.ClassLoader classLoader, org.xnio.XnioWorker xnioWorker, io.undertow.connector.ByteBufferPool bufferPool, java.util.List<io.undertow.servlet.api.ThreadSetupHandler> threadSetupHandlers, boolean dispatchToWorker, java.net.InetSocketAddress clientBindAddress, WebSocketReconnectHandler reconnectHandler)
-
ServerWebSocketContainer
public ServerWebSocketContainer(io.undertow.servlet.api.ClassIntrospecter classIntrospecter, java.lang.ClassLoader classLoader, org.xnio.XnioWorker xnioWorker, io.undertow.connector.ByteBufferPool bufferPool, java.util.List<io.undertow.servlet.api.ThreadSetupHandler> threadSetupHandlers, boolean dispatchToWorker, java.net.InetSocketAddress clientBindAddress, WebSocketReconnectHandler reconnectHandler, java.util.List<javax.websocket.Extension> installedExtensions)
-
-
Method Detail
-
getDefaultAsyncSendTimeout
public long getDefaultAsyncSendTimeout()
- Specified by:
getDefaultAsyncSendTimeout
in interfacejavax.websocket.WebSocketContainer
-
setAsyncSendTimeout
public void setAsyncSendTimeout(long defaultAsyncSendTimeout)
- Specified by:
setAsyncSendTimeout
in interfacejavax.websocket.WebSocketContainer
-
connectToServer
public javax.websocket.Session connectToServer(java.lang.Object annotatedEndpointInstance, io.undertow.websockets.client.WebSocketClient.ConnectionBuilder connectionBuilder) throws javax.websocket.DeploymentException, java.io.IOException
- Throws:
javax.websocket.DeploymentException
java.io.IOException
-
connectToServer
public javax.websocket.Session connectToServer(java.lang.Object annotatedEndpointInstance, java.net.URI path) throws javax.websocket.DeploymentException, java.io.IOException
- Specified by:
connectToServer
in interfacejavax.websocket.WebSocketContainer
- Throws:
javax.websocket.DeploymentException
java.io.IOException
-
connectToServer
public javax.websocket.Session connectToServer(java.lang.Class<?> aClass, io.undertow.websockets.client.WebSocketClient.ConnectionBuilder connectionBuilder) throws javax.websocket.DeploymentException, java.io.IOException
- Throws:
javax.websocket.DeploymentException
java.io.IOException
-
connectToServer
public javax.websocket.Session connectToServer(java.lang.Class<?> aClass, java.net.URI uri) throws javax.websocket.DeploymentException, java.io.IOException
- Specified by:
connectToServer
in interfacejavax.websocket.WebSocketContainer
- Throws:
javax.websocket.DeploymentException
java.io.IOException
-
connectToServer
public javax.websocket.Session connectToServer(javax.websocket.Endpoint endpointInstance, javax.websocket.ClientEndpointConfig config, java.net.URI path) throws javax.websocket.DeploymentException, java.io.IOException
- Specified by:
connectToServer
in interfacejavax.websocket.WebSocketContainer
- Throws:
javax.websocket.DeploymentException
java.io.IOException
-
connectToServer
public javax.websocket.Session connectToServer(javax.websocket.Endpoint endpointInstance, javax.websocket.ClientEndpointConfig config, io.undertow.websockets.client.WebSocketClient.ConnectionBuilder connectionBuilder) throws javax.websocket.DeploymentException, java.io.IOException
- Throws:
javax.websocket.DeploymentException
java.io.IOException
-
connectToServer
public javax.websocket.Session connectToServer(java.lang.Class<? extends javax.websocket.Endpoint> endpointClass, javax.websocket.ClientEndpointConfig cec, java.net.URI path) throws javax.websocket.DeploymentException, java.io.IOException
- Specified by:
connectToServer
in interfacejavax.websocket.WebSocketContainer
- Throws:
javax.websocket.DeploymentException
java.io.IOException
-
doUpgrade
public void doUpgrade(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, javax.websocket.server.ServerEndpointConfig sec, java.util.Map<java.lang.String,java.lang.String> pathParams) throws javax.servlet.ServletException, java.io.IOException
- Throws:
javax.servlet.ServletException
java.io.IOException
-
getDefaultMaxSessionIdleTimeout
public long getDefaultMaxSessionIdleTimeout()
- Specified by:
getDefaultMaxSessionIdleTimeout
in interfacejavax.websocket.WebSocketContainer
-
setDefaultMaxSessionIdleTimeout
public void setDefaultMaxSessionIdleTimeout(long timeout)
- Specified by:
setDefaultMaxSessionIdleTimeout
in interfacejavax.websocket.WebSocketContainer
-
getDefaultMaxBinaryMessageBufferSize
public int getDefaultMaxBinaryMessageBufferSize()
- Specified by:
getDefaultMaxBinaryMessageBufferSize
in interfacejavax.websocket.WebSocketContainer
-
setDefaultMaxBinaryMessageBufferSize
public void setDefaultMaxBinaryMessageBufferSize(int defaultMaxBinaryMessageBufferSize)
- Specified by:
setDefaultMaxBinaryMessageBufferSize
in interfacejavax.websocket.WebSocketContainer
-
getDefaultMaxTextMessageBufferSize
public int getDefaultMaxTextMessageBufferSize()
- Specified by:
getDefaultMaxTextMessageBufferSize
in interfacejavax.websocket.WebSocketContainer
-
setDefaultMaxTextMessageBufferSize
public void setDefaultMaxTextMessageBufferSize(int defaultMaxTextMessageBufferSize)
- Specified by:
setDefaultMaxTextMessageBufferSize
in interfacejavax.websocket.WebSocketContainer
-
getInstalledExtensions
public java.util.Set<javax.websocket.Extension> getInstalledExtensions()
- Specified by:
getInstalledExtensions
in interfacejavax.websocket.WebSocketContainer
-
invokeEndpointMethod
public void invokeEndpointMethod(java.util.concurrent.Executor executor, java.lang.Runnable invocation)
Runs a web socket invocation, setting up the threads and dispatching a thread poolUnfortunately 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(java.lang.Runnable invocation)
Directly invokes an endpoint method, without dispatching to an executor- Parameters:
invocation
- The invocation
-
addEndpoint
public void addEndpoint(java.lang.Class<?> endpoint) throws javax.websocket.DeploymentException
- Specified by:
addEndpoint
in interfacejavax.websocket.server.ServerContainer
- Throws:
javax.websocket.DeploymentException
-
addEndpoint
public void addEndpoint(javax.websocket.server.ServerEndpointConfig endpoint) throws javax.websocket.DeploymentException
- Specified by:
addEndpoint
in interfacejavax.websocket.server.ServerContainer
- Throws:
javax.websocket.DeploymentException
-
deploymentComplete
public void deploymentComplete()
-
getConfiguredServerEndpoints
public java.util.List<ConfiguredServerEndpoint> getConfiguredServerEndpoints()
-
getContextToAddFilter
public io.undertow.servlet.spec.ServletContextImpl getContextToAddFilter()
-
setContextToAddFilter
public void setContextToAddFilter(io.undertow.servlet.spec.ServletContextImpl contextToAddFilter)
-
close
public void close(int waitTime)
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
-
getBufferPool
public io.undertow.connector.ByteBufferPool getBufferPool()
-
getXnioWorker
public org.xnio.XnioWorker getXnioWorker()
-
pause
public void pause(ServerWebSocketContainer.PauseListener listener)
Pauses the container- Parameters:
listener
-
-
resume
public void resume()
resumes a paused container
-
getWebSocketReconnectHandler
public WebSocketReconnectHandler getWebSocketReconnectHandler()
-
isClosed
public boolean isClosed()
-
isDispatchToWorker
public boolean isDispatchToWorker()
-
-