public class StreamingSockJsSession extends AbstractHttpSockJsSession
Modifier and Type | Field and Description |
---|---|
private int |
byteCount |
DISCONNECTED_CLIENT_LOG_CATEGORY, disconnectedClientLogger, logger
Constructor and Description |
---|
StreamingSockJsSession(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 boolean |
isStreaming()
Whether this HTTP transport streams message frames vs closing the response
after each frame written (long polling).
|
disconnect, getAcceptedProtocol, getBinaryMessageSizeLimit, getExtensions, getHandshakeHeaders, getLocalAddress, getMessageCache, getPrincipal, getRemoteAddress, getTextMessageSizeLimit, getUri, handleInitialRequest, handleSuccessiveRequest, isActive, resetRequest, sendMessageInternal, setAcceptedProtocol, setBinaryMessageSizeLimit, setTextMessageSizeLimit, writeFrameInternal, writePrelude
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(java.lang.String sessionId, SockJsServiceConfig config, WebSocketHandler wsHandler, java.util.Map<java.lang.String,java.lang.Object> attributes)
protected boolean isStreaming()
AbstractHttpSockJsSession
isStreaming
in class AbstractHttpSockJsSession
protected void flushCache() throws SockJsTransportFailureException
AbstractHttpSockJsSession
flushCache
in class AbstractHttpSockJsSession
SockJsTransportFailureException