public abstract class StreamingSockJsSession extends AbstractHttpSockJsSession
DISCONNECTED_CLIENT_LOG_CATEGORY, disconnectedClientLogger, logger, responseLock
Constructor and Description |
---|
StreamingSockJsSession(String sessionId,
SockJsServiceConfig config,
WebSocketHandler wsHandler,
Map<String,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 abstract byte[] |
getPrelude(ServerHttpRequest request)
Get the prelude to write to the response before any other data.
|
protected void |
handleRequestInternal(ServerHttpRequest request,
ServerHttpResponse response,
boolean initialRequest)
Invoked when a SockJS transport request is received.
|
disconnect, getAcceptedProtocol, getBinaryMessageSizeLimit, getExtensions, getHandshakeHeaders, getLocalAddress, getMessageCache, getPrincipal, getRemoteAddress, getTextMessageSizeLimit, getUri, handleInitialRequest, handleSuccessiveRequest, isActive, resetRequest, sendMessageInternal, setAcceptedProtocol, setBinaryMessageSizeLimit, setTextMessageSizeLimit, writeFrameInternal
cancelHeartbeat, close, close, delegateConnectionClosed, delegateConnectionEstablished, delegateError, delegateMessages, disableHeartbeat, getAttributes, getId, getMessageCodec, getSockJsServiceConfig, getTimeSinceLastActive, isClosed, isNew, isOpen, scheduleHeartbeat, sendHeartbeat, sendMessage, toString, tryCloseWithSockJsTransportError, updateLastActiveTime, writeFrame
public StreamingSockJsSession(String sessionId, SockJsServiceConfig config, WebSocketHandler wsHandler, Map<String,Object> attributes)
protected abstract byte[] getPrelude(ServerHttpRequest request)
protected void handleRequestInternal(ServerHttpRequest request, ServerHttpResponse response, boolean initialRequest) throws IOException
AbstractHttpSockJsSession
handleRequestInternal
in class AbstractHttpSockJsSession
request
- the current requestresponse
- the current responseinitialRequest
- whether it is the first request for the sessionIOException
protected void flushCache() throws SockJsTransportFailureException
AbstractHttpSockJsSession
flushCache
in class AbstractHttpSockJsSession
SockJsTransportFailureException