public class PollingSockJsSession extends AbstractHttpSockJsSession
DISCONNECTED_CLIENT_LOG_CATEGORY, disconnectedClientLogger, logger, responseLock| Constructor and Description |
|---|
PollingSockJsSession(java.lang.String sessionId,
SockJsServiceConfig config,
WebSocketHandler wsHandler,
java.util.Map<java.lang.String,java.lang.Object> attributes) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
flushCache()
Called when the connection is active and ready to write to the response.
|
protected void |
handleRequestInternal(ServerHttpRequest request,
ServerHttpResponse response,
boolean initialRequest)
Invoked when a SockJS transport request is received.
|
protected boolean |
isStreaming()
Deprecated.
as of 4.2 this method is no longer used.
|
protected void |
writeFrame(SockJsFrame frame)
For internal use within a TransportHandler and the (TransportHandler-specific)
session class.
|
disconnect, getAcceptedProtocol, getBinaryMessageSizeLimit, getExtensions, getHandshakeHeaders, getLocalAddress, getMessageCache, getPrincipal, getRemoteAddress, getTextMessageSizeLimit, getUri, handleInitialRequest, handleSuccessiveRequest, isActive, resetRequest, sendMessageInternal, setAcceptedProtocol, setBinaryMessageSizeLimit, setTextMessageSizeLimit, writeFrameInternal, writePreludecancelHeartbeat, close, close, delegateConnectionClosed, delegateConnectionEstablished, delegateError, delegateMessages, disableHeartbeat, getAttributes, getId, getMessageCodec, getSockJsServiceConfig, getTimeSinceLastActive, isClosed, isNew, isOpen, scheduleHeartbeat, sendHeartbeat, sendMessage, toString, tryCloseWithSockJsTransportError, updateLastActiveTimepublic PollingSockJsSession(java.lang.String sessionId,
SockJsServiceConfig config,
WebSocketHandler wsHandler,
java.util.Map<java.lang.String,java.lang.Object> attributes)
@Deprecated protected boolean isStreaming()
isStreaming in class AbstractHttpSockJsSessionprotected void handleRequestInternal(ServerHttpRequest request, ServerHttpResponse response, boolean initialRequest) throws java.io.IOException
AbstractHttpSockJsSessionhandleRequestInternal in class AbstractHttpSockJsSessionrequest - the current requestresponse - the current responseinitialRequest - whether it is the first request for the sessionjava.io.IOExceptionprotected void flushCache()
throws SockJsTransportFailureException
AbstractHttpSockJsSessionflushCache in class AbstractHttpSockJsSessionSockJsTransportFailureExceptionprotected void writeFrame(SockJsFrame frame) throws SockJsTransportFailureException
AbstractSockJsSessionwriteFrame in class AbstractSockJsSessionSockJsTransportFailureException