public class StreamingSockJsSession extends AbstractHttpSockJsSession
logger
Constructor and Description |
---|
StreamingSockJsSession(String sessionId,
SockJsServiceConfig config,
WebSocketHandler wsHandler,
Map<String,Object> attributes) |
Modifier and Type | Method and Description |
---|---|
protected void |
flushCache()
Only called if the connection is currently active
|
void |
handleInitialRequest(ServerHttpRequest request,
ServerHttpResponse response,
SockJsFrameFormat frameFormat) |
protected void |
resetRequest() |
protected void |
writeFrameInternal(SockJsFrame frame) |
afterRequestUpdated, disconnect, getAcceptedProtocol, getExtensions, getHandshakeHeaders, getLocalAddress, getMessageCache, getPrincipal, getRemoteAddress, getRequest, getResponse, getUri, isActive, sendMessageInternal, setAcceptedProtocol, startLongPollingRequest, writePrelude
cancelHeartbeat, close, close, delegateConnectionClosed, delegateConnectionEstablished, delegateError, delegateMessages, getHandshakeAttributes, getId, getSockJsServiceConfig, getTimeSinceLastActive, isClosed, isNew, isOpen, scheduleHeartbeat, sendHeartbeat, sendMessage, toString, tryCloseWithSockJsTransportError, updateLastActiveTime, writeFrame
public StreamingSockJsSession(String sessionId, SockJsServiceConfig config, WebSocketHandler wsHandler, Map<String,Object> attributes)
public void handleInitialRequest(ServerHttpRequest request, ServerHttpResponse response, SockJsFrameFormat frameFormat) throws SockJsException
handleInitialRequest
in class AbstractHttpSockJsSession
SockJsException
protected void flushCache() throws SockJsTransportFailureException
AbstractHttpSockJsSession
flushCache
in class AbstractHttpSockJsSession
SockJsTransportFailureException
protected void resetRequest()
resetRequest
in class AbstractHttpSockJsSession
protected void writeFrameInternal(SockJsFrame frame) throws IOException
writeFrameInternal
in class AbstractHttpSockJsSession
IOException