public abstract class AbstractHttpReceivingTransportHandler extends AbstractTransportHandler
logger, UTF8_CHARSET
Constructor and Description |
---|
AbstractHttpReceivingTransportHandler() |
Modifier and Type | Method and Description |
---|---|
protected abstract org.springframework.http.HttpStatus |
getResponseStatus() |
void |
handleRequest(org.springframework.http.server.ServerHttpRequest request,
org.springframework.http.server.ServerHttpResponse response,
WebSocketHandler wsHandler,
SockJsSession wsSession)
Handle the given request and delegate messages to the provided
WebSocketHandler . |
protected void |
handleRequestInternal(org.springframework.http.server.ServerHttpRequest request,
org.springframework.http.server.ServerHttpResponse response,
WebSocketHandler wsHandler,
AbstractHttpSockJsSession sockJsSession) |
protected abstract String[] |
readMessages(org.springframework.http.server.ServerHttpRequest request) |
getServiceConfig, initialize
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getTransportType
public AbstractHttpReceivingTransportHandler()
public final void handleRequest(org.springframework.http.server.ServerHttpRequest request, org.springframework.http.server.ServerHttpResponse response, WebSocketHandler wsHandler, SockJsSession wsSession) throws SockJsException
TransportHandler
WebSocketHandler
.request
- the current requestresponse
- the current responsewsHandler
- the target WebSocketHandler (never null
)wsSession
- the SockJS session (never null
)SockJsException
- raised when request processing fails as
explained in SockJsService
protected void handleRequestInternal(org.springframework.http.server.ServerHttpRequest request, org.springframework.http.server.ServerHttpResponse response, WebSocketHandler wsHandler, AbstractHttpSockJsSession sockJsSession) throws SockJsException
SockJsException
protected abstract String[] readMessages(org.springframework.http.server.ServerHttpRequest request) throws IOException
IOException
protected abstract org.springframework.http.HttpStatus getResponseStatus()