public class StreamingSockJsSession extends AbstractHttpSockJsSession
Modifier and Type | Field and Description |
---|---|
private int |
byteCount |
logger
Constructor and Description |
---|
StreamingSockJsSession(java.lang.String sessionId,
SockJsConfiguration config,
WebSocketHandler handler) |
Modifier and Type | Method and Description |
---|---|
protected void |
flushCache()
Only called if the connection is currently active
|
protected void |
resetRequest() |
void |
setInitialRequest(ServerHttpRequest request,
ServerHttpResponse response,
SockJsFrame.FrameFormat frameFormat) |
protected void |
writeFrameInternal(SockJsFrame frame) |
disconnect, getMessageCache, getRequest, getResponse, isActive, sendMessageInternal, setLongPollingRequest, writePrelude
cancelHeartbeat, close, close, delegateConnectionClosed, delegateConnectionEstablished, delegateError, delegateMessages, getId, getPrincipal, getRemoteAddress, getRemoteHostName, getSockJsConfig, getTimeSinceLastActive, getUri, isClosed, isNew, isOpen, isSecure, scheduleHeartbeat, sendHeartbeat, sendMessage, setPrincipal, setRemoteAddress, setRemoteHostName, setUri, toString, tryCloseWithSockJsTransportError, updateLastActiveTime, writeFrame
public StreamingSockJsSession(java.lang.String sessionId, SockJsConfiguration config, WebSocketHandler handler)
public void setInitialRequest(ServerHttpRequest request, ServerHttpResponse response, SockJsFrame.FrameFormat frameFormat) throws TransportErrorException
setInitialRequest
in class AbstractHttpSockJsSession
TransportErrorException
protected void flushCache() throws java.io.IOException
AbstractHttpSockJsSession
flushCache
in class AbstractHttpSockJsSession
java.io.IOException
protected void resetRequest()
resetRequest
in class AbstractHttpSockJsSession
protected void writeFrameInternal(SockJsFrame frame) throws java.io.IOException
writeFrameInternal
in class AbstractHttpSockJsSession
java.io.IOException