public abstract class AbstractHttpSockJsSession extends AbstractSockJsSession
logger| Constructor and Description |
|---|
AbstractHttpSockJsSession(java.lang.String sessionId,
SockJsConfiguration config,
WebSocketHandler handler) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
disconnect(CloseStatus status) |
protected abstract void |
flushCache()
Only called if the connection is currently active
|
protected java.util.concurrent.BlockingQueue<java.lang.String> |
getMessageCache() |
protected ServerHttpRequest |
getRequest() |
protected ServerHttpResponse |
getResponse() |
boolean |
isActive()
Polling and Streaming sessions periodically close the current HTTP request and
wait for the next request to come through.
|
protected void |
resetRequest() |
protected void |
sendMessageInternal(java.lang.String message) |
void |
setInitialRequest(ServerHttpRequest request,
ServerHttpResponse response,
SockJsFrame.FrameFormat frameFormat) |
void |
setLongPollingRequest(ServerHttpRequest request,
ServerHttpResponse response,
SockJsFrame.FrameFormat frameFormat) |
protected void |
writeFrameInternal(SockJsFrame frame) |
protected void |
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, writeFramepublic AbstractHttpSockJsSession(java.lang.String sessionId,
SockJsConfiguration config,
WebSocketHandler handler)
public void setInitialRequest(ServerHttpRequest request, ServerHttpResponse response, SockJsFrame.FrameFormat frameFormat) throws TransportErrorException
TransportErrorExceptionprotected void writePrelude()
throws java.io.IOException
java.io.IOExceptionpublic void setLongPollingRequest(ServerHttpRequest request, ServerHttpResponse response, SockJsFrame.FrameFormat frameFormat) throws TransportErrorException
TransportErrorExceptionpublic boolean isActive()
AbstractSockJsSessionisActive in class AbstractSockJsSessionprotected java.util.concurrent.BlockingQueue<java.lang.String> getMessageCache()
protected ServerHttpRequest getRequest()
protected ServerHttpResponse getResponse()
protected final void sendMessageInternal(java.lang.String message)
throws java.io.IOException
sendMessageInternal in class AbstractSockJsSessionjava.io.IOExceptionprotected abstract void flushCache()
throws java.io.IOException
java.io.IOExceptionprotected void disconnect(CloseStatus status)
disconnect in class AbstractSockJsSessionprotected void resetRequest()
protected void writeFrameInternal(SockJsFrame frame) throws java.io.IOException
writeFrameInternal in class AbstractSockJsSessionjava.io.IOException