Class RestTemplateXhrTransport
- java.lang.Object
- org.springframework.web.socket.sockjs.client.AbstractXhrTransport
- org.springframework.web.socket.sockjs.client.RestTemplateXhrTransport
- All Implemented Interfaces:
InfoReceiver,Transport,XhrTransport
public class RestTemplateXhrTransport extends AbstractXhrTransport
AnXhrTransportimplementation that uses aRestTemplate.- Since:
- 4.1
- Author:
- Rossen Stoyanchev
Field Summary
Fields inherited from class org.springframework.web.socket.sockjs.client.AbstractXhrTransport
logger, PRELUDE
Constructor Summary
Constructors Constructor Description RestTemplateXhrTransport()RestTemplateXhrTransport(RestOperations restTemplate)
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidconnectInternal(TransportRequest transportRequest, WebSocketHandler handler, URI receiveUrl, HttpHeaders handshakeHeaders, XhrClientSockJsSession session, SettableListenableFuture<WebSocketSession> connectFuture)protected ResponseEntity<String>executeInfoRequestInternal(URI infoUrl, HttpHeaders headers)ResponseEntity<String>executeSendRequestInternal(URI url, HttpHeaders headers, TextMessage message)RestOperationsgetRestTemplate()Return the configuredRestTemplate.TaskExecutorgetTaskExecutor()Return the configuredTaskExecutor.voidsetTaskExecutor(TaskExecutor taskExecutor)Configure theTaskExecutorto use to execute XHR receive requests.Methods inherited from class org.springframework.web.socket.sockjs.client.AbstractXhrTransport
connect, executeInfoRequest, executeSendRequest, getTransportTypes, isXhrStreamingDisabled, setXhrStreamingDisabled
Constructor Detail
RestTemplateXhrTransport
public RestTemplateXhrTransport()
RestTemplateXhrTransport
public RestTemplateXhrTransport(RestOperations restTemplate)
Method Detail
getRestTemplate
public RestOperations getRestTemplate()
Return the configuredRestTemplate.
setTaskExecutor
public void setTaskExecutor(TaskExecutor taskExecutor)
Configure theTaskExecutorto use to execute XHR receive requests.By default
SimpleAsyncTaskExecutoris configured which creates a new thread every time the transports connects.
getTaskExecutor
public TaskExecutor getTaskExecutor()
Return the configuredTaskExecutor.
connectInternal
protected void connectInternal(TransportRequest transportRequest, WebSocketHandler handler, URI receiveUrl, HttpHeaders handshakeHeaders, XhrClientSockJsSession session, SettableListenableFuture<WebSocketSession> connectFuture)
- Specified by:
connectInternalin classAbstractXhrTransport
executeInfoRequestInternal
protected ResponseEntity<String> executeInfoRequestInternal(URI infoUrl, HttpHeaders headers)
- Specified by:
executeInfoRequestInternalin classAbstractXhrTransport
executeSendRequestInternal
public ResponseEntity<String> executeSendRequestInternal(URI url, HttpHeaders headers, TextMessage message)
- Specified by:
executeSendRequestInternalin classAbstractXhrTransport