Class JettyWebSocketServerContainer

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.util.component.ContainerLifeCycle

org.eclipse.jetty.ee8.websocket.server.JettyWebSocketServerContainer

All Implemented Interfaces:

EventListener, WebSocketContainer, WebSocketPolicy, Container, Destroyable, Dumpable, Dumpable.DumpableContainer, LifeCycle, LifeCycle.Listener

public class JettyWebSocketServerContainer
extends ContainerLifeCycle
implements WebSocketContainer, WebSocketPolicy, LifeCycle.Listener

Nested Class Summary

Nested classes/interfaces inherited from class AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener, AbstractLifeCycle.StopException

Nested classes/interfaces inherited from interface Container

Container.InheritedListener, Container.Listener

Nested classes/interfaces inherited from interface Dumpable

Dumpable.DumpableContainer

Nested classes/interfaces inherited from interface LifeCycle

LifeCycle.Listener

Field Summary

Fields

Modifier and Type	Field	Description
static final String	JETTY_WEBSOCKET_CONTAINER_ATTRIBUTE

Fields inherited from class AbstractLifeCycle

FAILED, STARTED, STARTING, STOPPED, STOPPING

Fields inherited from interface Dumpable

KEY

Method Summary

Modifier and Type	Method	Description
void	addMapping(String pathSpec, Class<?> endpointClass)
void	addMapping(String pathSpec, JettyWebSocketCreator creator)
void	addSessionListener(WebSocketSessionListener listener)	Register a WebSocketSessionListener with the container
void	dump(Appendable out, String indent)	Dump this object (and children) into an Appendable using the provided indent after any new lines.
static JettyWebSocketServerContainer	ensureContainer(javax.servlet.ServletContext servletContext)
WebSocketBehavior	getBehavior()
static JettyWebSocketServerContainer	getContainer(javax.servlet.ServletContext servletContext)
Executor	getExecutor()	The Container provided Executor.
Duration	getIdleTimeout()	The duration that a websocket may be idle before being closed by the implementation
int	getInputBufferSize()	The input (read from network layer) buffer size.
long	getMaxBinaryMessageSize()	Get the maximum size of a binary message during parsing.
long	getMaxFrameSize()	The maximum payload size of any WebSocket Frame which can be received.
long	getMaxTextMessageSize()	Get the maximum size of a text message during parsing.
Collection<Session>	getOpenSessions()	Get the collection of open Sessions being tracked by this container
int	getOutputBufferSize()	The output (write to network layer) buffer size.
boolean	isAutoFragment()	If true, frames are automatically fragmented to respect the maximum frame size.
void	notifySessionListeners(Consumer<WebSocketSessionListener> consumer)	Notify the Session Listeners of an event.
boolean	removeSessionListener(WebSocketSessionListener listener)	Remove a WebSocketSessionListener from the container
void	setAutoFragment(boolean autoFragment)	If set to true, frames are automatically fragmented to respect the maximum frame size.
void	setIdleTimeout(Duration duration)	The duration that a websocket may be idle before being closed by the implementation
void	setInputBufferSize(int size)	The input (read from network layer) buffer size.
void	setMaxBinaryMessageSize(long size)	The maximum size of a binary message during parsing/generating.
void	setMaxFrameSize(long maxFrameSize)	The maximum payload size of any WebSocket Frame which can be received.
void	setMaxTextMessageSize(long size)	The maximum size of a text message during parsing/generating.
void	setOutputBufferSize(int size)	The output (write to network layer) buffer size.
boolean	upgrade(JettyWebSocketCreator creator, javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response)	An immediate programmatic WebSocket upgrade that does not register a mapping or create a WebSocketUpgradeFilter.

Methods inherited from class ContainerLifeCycle

addBean, addBean, addEventListener, addManaged, contains, destroy, doStart, doStop, dump, dump, dumpObjects, dumpStdErr, getBean, getBeans, getBeans, getContainedBeans, getContainedBeans, installBean, installBean, isAuto, isManaged, isUnmanaged, manage, removeBean, removeBeans, removeEventListener, setBeans, start, stop, unmanage, updateBean, updateBean, updateBeans, updateBeans

Methods inherited from class AbstractLifeCycle

getEventListeners, getState, getState, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, setEventListeners, start, stop, toString

Methods inherited from class Object

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

Methods inherited from interface Container

getCachedBeans, getEventListeners

Methods inherited from interface Dumpable

dumpSelf

Methods inherited from interface Dumpable.DumpableContainer

isDumpable

Methods inherited from interface LifeCycle.Listener

lifeCycleFailure, lifeCycleStarted, lifeCycleStarting, lifeCycleStopped, lifeCycleStopping

Field Details

JETTY_WEBSOCKET_CONTAINER_ATTRIBUTE

public static final String JETTY_WEBSOCKET_CONTAINER_ATTRIBUTE

Method Details

getContainer

public static JettyWebSocketServerContainer getContainer(javax.servlet.ServletContext servletContext)

ensureContainer

public static JettyWebSocketServerContainer ensureContainer(javax.servlet.ServletContext servletContext)

addMapping

public void addMapping(String pathSpec,
 JettyWebSocketCreator creator)

addMapping

public void addMapping(String pathSpec,
 Class<?> endpointClass)

upgrade

public boolean upgrade(JettyWebSocketCreator creator,
 javax.servlet.http.HttpServletRequest request,
 javax.servlet.http.HttpServletResponse response)
                throws IOException

An immediate programmatic WebSocket upgrade that does not register a mapping or create a WebSocketUpgradeFilter.

A return value of true means the connection was Upgraded to WebSocket or an error response is being generated. A return value of false means that it was a bad upgrade request and couldn't be upgraded to WebSocket and the caller is responsible for generating the response.

Parameters:

creator - the WebSocketCreator to use.

request - the HttpServletRequest.

response - the HttpServletResponse.

Returns:

true if the connection could be upgraded or an error was sent.

Throws:

IOException - if an I/O error occurs.

getExecutor

public Executor getExecutor()

Description copied from interface: WebSocketContainer

The Container provided Executor.

Specified by:

getExecutor in interface WebSocketContainer

addSessionListener

public void addSessionListener(WebSocketSessionListener listener)

Description copied from interface: WebSocketContainer

Register a WebSocketSessionListener with the container

Specified by:

addSessionListener in interface WebSocketContainer

Parameters:

listener - the listener

removeSessionListener

public boolean removeSessionListener(WebSocketSessionListener listener)

Description copied from interface: WebSocketContainer

Remove a WebSocketSessionListener from the container

Specified by:

removeSessionListener in interface WebSocketContainer

Parameters:

listener - the listener

Returns:

true if listener was present and removed

notifySessionListeners

public void notifySessionListeners(Consumer<WebSocketSessionListener> consumer)

Description copied from interface: WebSocketContainer

Notify the Session Listeners of an event.

Specified by:

notifySessionListeners in interface WebSocketContainer

Parameters:

consumer - the consumer to call for each tracked listener

getOpenSessions

public Collection<Session> getOpenSessions()

Description copied from interface: WebSocketContainer

Get the collection of open Sessions being tracked by this container

Specified by:

getOpenSessions in interface WebSocketContainer

Returns:

the collection of open sessions

getBehavior

public WebSocketBehavior getBehavior()

Specified by:

getBehavior in interface WebSocketPolicy

getIdleTimeout

public Duration getIdleTimeout()

Description copied from interface: WebSocketPolicy

The duration that a websocket may be idle before being closed by the implementation

Specified by:

getIdleTimeout in interface WebSocketPolicy

Returns:

the timeout duration

getInputBufferSize

public int getInputBufferSize()

Description copied from interface: WebSocketPolicy

The input (read from network layer) buffer size.

This is the raw read operation buffer size, before the parsing of the websocket frames.

Specified by:

getInputBufferSize in interface WebSocketPolicy

Returns:

the raw network buffer input size.

getOutputBufferSize

public int getOutputBufferSize()

Description copied from interface: WebSocketPolicy

The output (write to network layer) buffer size.

This is the raw write operation buffer size and has no relationship to the websocket frame.

Specified by:

getOutputBufferSize in interface WebSocketPolicy

Returns:

the raw network buffer output size.

getMaxBinaryMessageSize

public long getMaxBinaryMessageSize()

Description copied from interface: WebSocketPolicy

Get the maximum size of a binary message during parsing.

This is a memory conservation option, memory over this limit will not be allocated by Jetty for handling binary messages. This applies to individual frames, whole message handling, and partial message handling.

Binary messages over this maximum will result in a close code 1009 StatusCode.MESSAGE_TOO_LARGE

Specified by:

getMaxBinaryMessageSize in interface WebSocketPolicy

Returns:

the maximum size of a binary message

getMaxTextMessageSize

public long getMaxTextMessageSize()

Description copied from interface: WebSocketPolicy

Get the maximum size of a text message during parsing.

This is a memory conservation option, memory over this limit will not be allocated by Jetty for handling text messages. This applies to individual frames, whole message handling, and partial message handling.

Text messages over this maximum will result in a close code 1009 StatusCode.MESSAGE_TOO_LARGE

Specified by:

getMaxTextMessageSize in interface WebSocketPolicy

Returns:

the maximum size of a text message.

getMaxFrameSize

public long getMaxFrameSize()

Description copied from interface: WebSocketPolicy

The maximum payload size of any WebSocket Frame which can be received.

Specified by:

getMaxFrameSize in interface WebSocketPolicy

Returns:

the maximum size of a WebSocket Frame.

isAutoFragment

public boolean isAutoFragment()

Description copied from interface: WebSocketPolicy

If true, frames are automatically fragmented to respect the maximum frame size.

Specified by:

isAutoFragment in interface WebSocketPolicy

Returns:

whether to automatically fragment incoming WebSocket Frames.

setIdleTimeout

public void setIdleTimeout(Duration duration)

Description copied from interface: WebSocketPolicy

The duration that a websocket may be idle before being closed by the implementation

Specified by:

setIdleTimeout in interface WebSocketPolicy

Parameters:

duration - the timeout duration (may not be null or negative)

setInputBufferSize

public void setInputBufferSize(int size)

Description copied from interface: WebSocketPolicy

The input (read from network layer) buffer size.

Specified by:

setInputBufferSize in interface WebSocketPolicy

Parameters:

size - the size in bytes

setOutputBufferSize

public void setOutputBufferSize(int size)

Description copied from interface: WebSocketPolicy

The output (write to network layer) buffer size.

Specified by:

setOutputBufferSize in interface WebSocketPolicy

Parameters:

size - the size in bytes

setMaxBinaryMessageSize

public void setMaxBinaryMessageSize(long size)

Description copied from interface: WebSocketPolicy

The maximum size of a binary message during parsing/generating.

Binary messages over this maximum will result in a close code 1009 StatusCode.MESSAGE_TOO_LARGE

Specified by:

setMaxBinaryMessageSize in interface WebSocketPolicy

Parameters:

size - the maximum allowed size of a binary message.

setMaxTextMessageSize

public void setMaxTextMessageSize(long size)

Description copied from interface: WebSocketPolicy

The maximum size of a text message during parsing/generating.

Text messages over this maximum will result in a close code 1009 StatusCode.MESSAGE_TOO_LARGE

Specified by:

setMaxTextMessageSize in interface WebSocketPolicy

Parameters:

size - the maximum allowed size of a text message.

setMaxFrameSize

public void setMaxFrameSize(long maxFrameSize)

Description copied from interface: WebSocketPolicy

The maximum payload size of any WebSocket Frame which can be received.

WebSocket Frames over this maximum will result in a close code 1009 StatusCode.MESSAGE_TOO_LARGE

Specified by:

setMaxFrameSize in interface WebSocketPolicy

Parameters:

maxFrameSize - the maximum allowed size of a WebSocket Frame.

setAutoFragment

public void setAutoFragment(boolean autoFragment)

Description copied from interface: WebSocketPolicy

If set to true, frames are automatically fragmented to respect the maximum frame size.

Specified by:

setAutoFragment in interface WebSocketPolicy

Parameters:

autoFragment - whether to automatically fragment incoming WebSocket Frames.

dump

public void dump(Appendable out,
 String indent)
          throws IOException

Description copied from interface: Dumpable

Dump this object (and children) into an Appendable using the provided indent after any new lines. The indent should not be applied to the first object dumped.

Specified by:

dump in interface Dumpable

Overrides:

dump in class ContainerLifeCycle

Parameters:

out - The appendable to dump to

indent - The indent to apply after any new lines.

Throws:

IOException - if unable to write to Appendable