Class RestClientXhrTransport

java.lang.Object

org.springframework.web.socket.sockjs.client.AbstractXhrTransport

org.springframework.web.socket.sockjs.client.RestClientXhrTransport

All Implemented Interfaces:

InfoReceiver, Transport, XhrTransport

public class RestClientXhrTransport
extends AbstractXhrTransport

An XhrTransport implementation that uses a RestClient.

Since:

7.0.7

Author:

Brian Clozel, Rossen Stoyanchev

Field Summary

Fields inherited from class AbstractXhrTransport

logger, PRELUDE

Constructor Summary

Constructors

Constructor	Description
RestClientXhrTransport()
RestClientXhrTransport(org.springframework.web.client.RestClient restClient)

Method Summary

Modifier and Type	Method	Description
protected void	connectInternal(TransportRequest transportRequest, WebSocketHandler handler, URI receiveUrl, org.springframework.http.HttpHeaders handshakeHeaders, XhrClientSockJsSession session, CompletableFuture<WebSocketSession> connectFuture)
protected org.springframework.http.ResponseEntity<String>	executeInfoRequestInternal(URI infoUrl, org.springframework.http.HttpHeaders headers)
org.springframework.http.ResponseEntity<String>	executeSendRequestInternal(URI url, org.springframework.http.HttpHeaders headers, TextMessage message)
org.springframework.web.client.RestClient	getRestClient()	Return the configured RestClient.
org.springframework.core.task.TaskExecutor	getTaskExecutor()	Return the configured TaskExecutor.
void	setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)	Configure the TaskExecutor to use to execute XHR receive requests.

Methods inherited from class AbstractXhrTransport

connectAsync, executeInfoRequest, executeSendRequest, getTransportTypes, isXhrStreamingDisabled, setXhrStreamingDisabled

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RestClientXhrTransport

public RestClientXhrTransport()

RestClientXhrTransport

public RestClientXhrTransport(org.springframework.web.client.RestClient restClient)

Method Details

getRestClient

public org.springframework.web.client.RestClient getRestClient()

Return the configured RestClient.

setTaskExecutor

public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)

Configure the TaskExecutor to use to execute XHR receive requests.

By default SimpleAsyncTaskExecutor is configured which creates a new thread every time the transports connects.

getTaskExecutor

public org.springframework.core.task.TaskExecutor getTaskExecutor()

Return the configured TaskExecutor.

connectInternal

protected void connectInternal(TransportRequest transportRequest,
 WebSocketHandler handler,
 URI receiveUrl,
 org.springframework.http.HttpHeaders handshakeHeaders,
 XhrClientSockJsSession session,
 CompletableFuture<WebSocketSession> connectFuture)

Specified by:

connectInternal in class AbstractXhrTransport

executeInfoRequestInternal

protected org.springframework.http.ResponseEntity<String> executeInfoRequestInternal(URI infoUrl,
 org.springframework.http.HttpHeaders headers)

Specified by:

executeInfoRequestInternal in class AbstractXhrTransport

executeSendRequestInternal

public org.springframework.http.ResponseEntity<String> executeSendRequestInternal(URI url,
 org.springframework.http.HttpHeaders headers,
 TextMessage message)

Specified by:

executeSendRequestInternal in class AbstractXhrTransport