public class StreamingSockJsSession extends AbstractHttpSockJsSession
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, writePreludecancelHeartbeat, 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, writeFramepublic StreamingSockJsSession(java.lang.String sessionId,
SockJsConfiguration config,
WebSocketHandler handler)
public void setInitialRequest(ServerHttpRequest request, ServerHttpResponse response, SockJsFrame.FrameFormat frameFormat) throws TransportErrorException
setInitialRequest in class AbstractHttpSockJsSessionTransportErrorExceptionprotected void flushCache()
throws java.io.IOException
AbstractHttpSockJsSessionflushCache in class AbstractHttpSockJsSessionjava.io.IOExceptionprotected void resetRequest()
resetRequest in class AbstractHttpSockJsSessionprotected void writeFrameInternal(SockJsFrame frame) throws java.io.IOException
writeFrameInternal in class AbstractHttpSockJsSessionjava.io.IOException