org.springframework.integration.websocket

Class IntegrationWebSocketContainer

java.lang.Object

org.springframework.integration.websocket.IntegrationWebSocketContainer

All Implemented Interfaces:

DisposableBean

Direct Known Subclasses:

ClientWebSocketContainer, ServerWebSocketContainer

public abstract class IntegrationWebSocketContainer
extends java.lang.Object
implements DisposableBean

The high-level 'connection factory pattern' contract over low-level Web-Socket configuration.

Provides the composition for the internal WebSocketHandler implementation, which is used with native Web-Socket containers.

Collects established WebSocketSessions, which can be accessed using getSession(String).

Can accept the WebSocketListener to delegate WebSocketSession events from the internal IntegrationWebSocketContainer.IntegrationWebSocketHandler.

Supported sub-protocols can be configured, but SubProtocolCapable.getSubProtocols() have a precedent.

Since:

4.1

Author:

Artem Bilan

See Also:

WebSocketInboundChannelAdapter, WebSocketOutboundMessageHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.logging.Log	logger
protected java.util.Map<java.lang.String,WebSocketSession>	sessions
protected WebSocketHandler	webSocketHandler

Constructor Summary

Constructors

Constructor and Description
IntegrationWebSocketContainer()

Method Summary

Modifier and Type	Method and Description
void	addSupportedProtocols(java.lang.String... protocols)
void	closeSession(WebSocketSession session, CloseStatus closeStatus)
void	destroy()
WebSocketSession	getSession(java.lang.String sessionId)
java.util.Map<java.lang.String,WebSocketSession>	getSessions()
java.util.List<java.lang.String>	getSubProtocols()
void	setMessageListener(WebSocketListener messageListener)
void	setSendBufferSizeLimit(int sendBufferSizeLimit)
void	setSendTimeLimit(int sendTimeLimit)
void	setSupportedProtocols(java.lang.String... protocols)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.apache.commons.logging.Log logger

webSocketHandler

protected final WebSocketHandler webSocketHandler

sessions

protected final java.util.Map<java.lang.String,WebSocketSession> sessions

Constructor Detail

IntegrationWebSocketContainer

public IntegrationWebSocketContainer()

Method Detail

setSendTimeLimit

public void setSendTimeLimit(int sendTimeLimit)

setSendBufferSizeLimit

public void setSendBufferSizeLimit(int sendBufferSizeLimit)

setMessageListener

public void setMessageListener(WebSocketListener messageListener)

setSupportedProtocols

public void setSupportedProtocols(java.lang.String... protocols)

addSupportedProtocols

public void addSupportedProtocols(java.lang.String... protocols)

getSubProtocols

public java.util.List<java.lang.String> getSubProtocols()

getSessions

public java.util.Map<java.lang.String,WebSocketSession> getSessions()

getSession

public WebSocketSession getSession(java.lang.String sessionId)

closeSession

public void closeSession(WebSocketSession session,
                         CloseStatus closeStatus)
                  throws java.lang.Exception

Throws:

java.lang.Exception

destroy

public void destroy()
             throws java.lang.Exception

Specified by:

destroy in interface DisposableBean

Throws:

java.lang.Exception