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 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, Gary Russell

See Also:

WebSocketInboundChannelAdapter, WebSocketOutboundMessageHandler

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_SEND_BUFFER_SIZE
static int	DEFAULT_SEND_TIME_LIMIT
protected Log	logger
protected Map<String,WebSocketSession>	sessions
protected WebSocketHandler	webSocketHandler

Constructor Summary

Constructors

Constructor and Description
IntegrationWebSocketContainer()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_SEND_TIME_LIMIT

public static final int DEFAULT_SEND_TIME_LIMIT

See Also:

Constant Field Values

DEFAULT_SEND_BUFFER_SIZE

public static final int DEFAULT_SEND_BUFFER_SIZE

See Also:

Constant Field Values

logger

protected final Log logger

webSocketHandler

protected final WebSocketHandler webSocketHandler

sessions

protected final Map<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(String... protocols)

addSupportedProtocols

public void addSupportedProtocols(String... protocols)

getSubProtocols

public List<String> getSubProtocols()

getSessions

public Map<String,WebSocketSession> getSessions()

getSession

public WebSocketSession getSession(String sessionId)

closeSession

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

Throws:

Exception

destroy

public void destroy()

Specified by:

destroy in interface DisposableBean