类 RestTemplateXhrTransport
- java.lang.Object
- org.springframework.web.socket.sockjs.client.AbstractXhrTransport
- org.springframework.web.socket.sockjs.client.RestTemplateXhrTransport
- 所有已实现的接口:
InfoReceiver
,Transport
,XhrTransport
public class RestTemplateXhrTransport extends AbstractXhrTransport
AnXhrTransport
implementation that uses aRestTemplate
.- 从以下版本开始:
- 4.1
- 作者:
- Rossen Stoyanchev
字段概要
从类继承的字段 org.springframework.web.socket.sockjs.client.AbstractXhrTransport
logger, PRELUDE
构造器概要
构造器 构造器 说明 RestTemplateXhrTransport()
RestTemplateXhrTransport(RestOperations restTemplate)
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 protected void
connectInternal(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)
RestOperations
getRestTemplate()
Return the configuredRestTemplate
.TaskExecutor
getTaskExecutor()
Return the configuredTaskExecutor
.void
setTaskExecutor(TaskExecutor taskExecutor)
Configure theTaskExecutor
to use to execute XHR receive requests.从类继承的方法 org.springframework.web.socket.sockjs.client.AbstractXhrTransport
connect, executeInfoRequest, executeSendRequest, getTransportTypes, isXhrStreamingDisabled, setXhrStreamingDisabled
构造器详细资料
RestTemplateXhrTransport
public RestTemplateXhrTransport()
RestTemplateXhrTransport
public RestTemplateXhrTransport(RestOperations restTemplate)
方法详细资料
getRestTemplate
public RestOperations getRestTemplate()
Return the configuredRestTemplate
.
setTaskExecutor
public void setTaskExecutor(TaskExecutor taskExecutor)
Configure theTaskExecutor
to use to execute XHR receive requests.By default
SimpleAsyncTaskExecutor
is 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)
- 指定者:
connectInternal
在类中AbstractXhrTransport
executeInfoRequestInternal
protected ResponseEntity<String> executeInfoRequestInternal(URI infoUrl, HttpHeaders headers)
executeSendRequestInternal
public ResponseEntity<String> executeSendRequestInternal(URI url, HttpHeaders headers, TextMessage message)