Class webSocketClientSockJsSession

java.lang.Object

org.springframework.web.socket.sockjs.client.AbstractClientSockJsSession

org.springframework.web.socket.sockjs.client.webSocketClientSockJsSession

All Implemented Interfaces:

Closeable, AutoCloseable, NativewebSocketSession, webSocketSession

public class webSocketClientSockJsSession
extends AbstractClientSockJsSession
implements NativewebSocketSession

An extension of AbstractClientSockJsSession wrapping and delegating to an actual webSocket session.

Since:

4.1

Author:

Rossen Stoyanchev

Field Summary

Fields inherited from class AbstractClientSockJsSession

logger

Constructor Summary

Constructors

Constructor	Description
webSocketClientSockJsSession(TransportRequest request, webSocketHandler handler, CompletableFuture<webSocketSession> connectFuture)

Method Summary

Modifier and Type	Method	Description
protected void	disconnect(CloseStatus status)
@Nullable String	getAcceptedProtocol()	Return the negotiated sub-protocol.
int	getBinaryMessageSizeLimit()	Get the configured maximum size for an incoming binary message.
List<webSocketExtension>	getExtensions()	Determine the negotiated extensions.
@Nullable InetSocketAddress	getLocalAddress()	Return the address on which the request was received.
Object	getNativeSession()	Return the underlying native webSocketSession.
<T> @Nullable T	getNativeSession(@Nullable Class<T> requiredType)	Return the underlying native webSocketSession, if available.
@Nullable InetSocketAddress	getRemoteAddress()	Return the address of the remote client.
int	getTextMessageSizeLimit()	Get the configured maximum size for an incoming text message.
void	initializeDelegateSession(webSocketSession session)
protected void	sendInternal(TextMessage textMessage)
void	setBinaryMessageSizeLimit(int messageSizeLimit)	Configure the maximum size for an incoming binary message.
void	setTextMessageSizeLimit(int messageSizeLimit)	Configure the maximum size for an incoming text message.

Methods inherited from class AbstractClientSockJsSession

afterTransportClosed, close, close, closeInternal, getAttributes, getHandshakeHeaders, getId, getMessageCodec, getPrincipal, getUri, getwebSocketHandler, handleFrame, handleTransportError, isDisconnected, isOpen, sendMessage, toString

Methods inherited from class Object

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

Methods inherited from interface webSocketSession

close, close, getAttributes, getHandshakeHeaders, getId, getPrincipal, getUri, isOpen, sendMessage

Constructor Details

webSocketClientSockJsSession

public webSocketClientSockJsSession(TransportRequest request,
 webSocketHandler handler,
 CompletableFuture<webSocketSession> connectFuture)

Method Details

getNativeSession

public Object getNativeSession()

Description copied from interface: NativewebSocketSession

Return the underlying native webSocketSession.

Specified by:

getNativeSession in interface NativewebSocketSession

getNativeSession

public <T> @Nullable T getNativeSession(@Nullable Class<T> requiredType)

Description copied from interface: NativewebSocketSession

Return the underlying native webSocketSession, if available.

Specified by:

getNativeSession in interface NativewebSocketSession

Parameters:

requiredType - the required type of the session

Returns:

the native session of the required type, or null if not available

getLocalAddress

public @Nullable InetSocketAddress getLocalAddress()

Description copied from interface: webSocketSession

Return the address on which the request was received.

Note: The localAddress is not always possible to access, which is the case with the Standard webSocket client API, and accordingly StandardwebSocketClient returns null.

Specified by:

getLocalAddress in interface webSocketSession

getRemoteAddress

public @Nullable InetSocketAddress getRemoteAddress()

Description copied from interface: webSocketSession

Return the address of the remote client.

Specified by:

getRemoteAddress in interface webSocketSession

getAcceptedProtocol

public @Nullable String getAcceptedProtocol()

Description copied from interface: webSocketSession

Return the negotiated sub-protocol.

Specified by:

getAcceptedProtocol in interface webSocketSession

Returns:

the protocol identifier, or null if no protocol was specified or negotiated successfully

setTextMessageSizeLimit

public void setTextMessageSizeLimit(int messageSizeLimit)

Description copied from interface: webSocketSession

Configure the maximum size for an incoming text message.

Specified by:

setTextMessageSizeLimit in interface webSocketSession

getTextMessageSizeLimit

public int getTextMessageSizeLimit()

Description copied from interface: webSocketSession

Get the configured maximum size for an incoming text message.

Specified by:

getTextMessageSizeLimit in interface webSocketSession

setBinaryMessageSizeLimit

public void setBinaryMessageSizeLimit(int messageSizeLimit)

Description copied from interface: webSocketSession

Configure the maximum size for an incoming binary message.

Specified by:

setBinaryMessageSizeLimit in interface webSocketSession

getBinaryMessageSizeLimit

public int getBinaryMessageSizeLimit()

Description copied from interface: webSocketSession

Get the configured maximum size for an incoming binary message.

Specified by:

getBinaryMessageSizeLimit in interface webSocketSession

getExtensions

public List<webSocketExtension> getExtensions()

Description copied from interface: webSocketSession

Determine the negotiated extensions.

Specified by:

getExtensions in interface webSocketSession

Returns:

the list of extensions, or an empty list if no extension was specified or negotiated successfully

initializeDelegateSession

public void initializeDelegateSession(webSocketSession session)

sendInternal

protected void sendInternal(TextMessage textMessage)
                     throws IOException

Specified by:

sendInternal in class AbstractClientSockJsSession

Throws:

IOException

disconnect

protected void disconnect(CloseStatus status)
                   throws IOException

Specified by:

disconnect in class AbstractClientSockJsSession

Throws:

IOException