Package 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	Description
static final int	DEFAULT_SEND_BUFFER_SIZE
static final int	DEFAULT_SEND_TIME_LIMIT
protected final Log	logger
protected final Map<String,WebSocketSession>	sessions
protected final WebSocketHandler	webSocketHandler

Constructor Summary

Constructors

Constructor	Description
IntegrationWebSocketContainer()

Method Summary

Modifier and Type	Method	Description
void	addSupportedProtocols(String... protocols)
void	closeSession(WebSocketSession session, CloseStatus closeStatus)
void	destroy()
WebSocketSession	getSession(String sessionId)
Map<String,WebSocketSession>	getSessions()
List<String>	getSubProtocols()
WebSocketHandler	getWebSocketHandler()
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 Details

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 Details

IntegrationWebSocketContainer

public IntegrationWebSocketContainer()

Method Details

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)

getWebSocketHandler

public WebSocketHandler getWebSocketHandler()

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