接口的使用
org.springframework.util.concurrent.ListenableFuture
使用ListenableFuture的程序包 程序包 说明 org.springframework.core.task This package defines Spring's core TaskExecutor abstraction, and provides SyncTaskExecutor and SimpleAsyncTaskExecutor implementations.org.springframework.core.task.support Support classes for Spring's TaskExecutor abstraction.org.springframework.http.client Contains an abstraction over client-side HTTP.org.springframework.jca.work Convenience classes for scheduling based on the JCA WorkManager facility, as supported within ResourceAdapters.org.springframework.messaging.handler.invocation Common infrastructure for invoking message handler methods.org.springframework.messaging.simp.stomp Generic support for simple messaging protocols (like STOMP).org.springframework.messaging.tcp Contains abstractions and implementation classes for establishing TCP connections viaTcpOperations
, handling messages viaTcpConnectionHandler
, as well as sending messages viaTcpConnection
.org.springframework.messaging.tcp.reactor Contains support for TCP messaging based on Reactor.org.springframework.mock.http.client Mock implementations of client-side HTTP abstractions.org.springframework.scheduling.annotation Java 5 annotation for asynchronous method execution.org.springframework.scheduling.commonj Convenience classes for scheduling based on the CommonJ WorkManager/TimerManager facility, as supported by IBM WebSphere 6.0+ and BEA WebLogic 9.0+.org.springframework.scheduling.concurrent Scheduling convenience classes for thejava.util.concurrent
andjavax.enterprise.concurrent
packages, allowing to set up a ThreadPoolExecutor or ScheduledThreadPoolExecutor as a bean in a Spring context.org.springframework.scheduling.quartz Support classes for the open source scheduler Quartz, allowing to set up Quartz Schedulers, JobDetails and Triggers as beans in a Spring context.org.springframework.util.concurrent Useful genericjava.util.concurrent.Future
extensions.org.springframework.web.client Core package of the client-side web support.org.springframework.web.socket.client Client-side abstractions for WebSocket applications.org.springframework.web.socket.client.jetty Client-side support for the Jetty WebSocket API.org.springframework.web.socket.client.standard Client-side classes for use with standard Java WebSocket endpoints.org.springframework.web.socket.messaging WebSocket integration for Spring's messaging module.org.springframework.web.socket.sockjs.client SockJS client implementation ofWebSocketClient
.org.springframework.core.task中ListenableFuture的使用
返回ListenableFuture的org.springframework.core.task中的方法 修饰符和类型 方法 说明 ListenableFuture<?>
AsyncListenableTaskExecutor. submitListenable(Runnable task)
Submit aRunnable
task for execution, receiving aListenableFuture
representing that task.<T> ListenableFuture<T>
AsyncListenableTaskExecutor. submitListenable(Callable<T> task)
Submit aCallable
task for execution, receiving aListenableFuture
representing that task.ListenableFuture<?>
SimpleAsyncTaskExecutor. submitListenable(Runnable task)
<T> ListenableFuture<T>
SimpleAsyncTaskExecutor. submitListenable(Callable<T> task)
org.springframework.core.task.support中ListenableFuture的使用
返回ListenableFuture的org.springframework.core.task.support中的方法 修饰符和类型 方法 说明 ListenableFuture<?>
TaskExecutorAdapter. submitListenable(Runnable task)
<T> ListenableFuture<T>
TaskExecutorAdapter. submitListenable(Callable<T> task)
org.springframework.http.client中ListenableFuture的使用
返回ListenableFuture的org.springframework.http.client中的方法 修饰符和类型 方法 说明 ListenableFuture<ClientHttpResponse>
AsyncClientHttpRequest. executeAsync()
已过时。Execute this request asynchronously, resulting in a Future handle.ListenableFuture<ClientHttpResponse>
AsyncClientHttpRequestExecution. executeAsync(HttpRequest request, byte[] body)
已过时。Resume the request execution by invoking the next interceptor in the chain or executing the request to the remote service.ListenableFuture<ClientHttpResponse>
AsyncClientHttpRequestInterceptor. intercept(HttpRequest request, byte[] body, AsyncClientHttpRequestExecution execution)
已过时。Intercept the given request, and return a response future.org.springframework.jca.work中ListenableFuture的使用
返回ListenableFuture的org.springframework.jca.work中的方法 修饰符和类型 方法 说明 ListenableFuture<?>
WorkManagerTaskExecutor. submitListenable(Runnable task)
<T> ListenableFuture<T>
WorkManagerTaskExecutor. submitListenable(Callable<T> task)
org.springframework.messaging.handler.invocation中ListenableFuture的使用
返回ListenableFuture的org.springframework.messaging.handler.invocation中的方法 修饰符和类型 方法 说明 ListenableFuture<?>
AsyncHandlerMethodReturnValueHandler. toListenableFuture(Object returnValue, MethodParameter returnType)
Adapt the asynchronous return value to aListenableFuture
.ListenableFuture<?>
CompletableFutureReturnValueHandler. toListenableFuture(Object returnValue, MethodParameter returnType)
ListenableFuture<?>
HandlerMethodReturnValueHandlerComposite. toListenableFuture(Object returnValue, MethodParameter returnType)
ListenableFuture<?>
ListenableFutureReturnValueHandler. toListenableFuture(Object returnValue, MethodParameter returnType)
ListenableFuture<?>
ReactiveReturnValueHandler. toListenableFuture(Object returnValue, MethodParameter returnType)
org.springframework.messaging.simp.stomp中ListenableFuture的使用
返回ListenableFuture的org.springframework.messaging.simp.stomp中的方法 修饰符和类型 方法 说明 ListenableFuture<StompSession>
ReactorNettyTcpStompClient. connect(StompHeaders connectHeaders, StompSessionHandler handler)
An overloaded version ofReactorNettyTcpStompClient.connect(StompSessionHandler)
that accepts headers to use for the STOMP CONNECT frame.ListenableFuture<StompSession>
ReactorNettyTcpStompClient. connect(StompSessionHandler handler)
Connect and notify the givenStompSessionHandler
when connected on the STOMP level.ListenableFuture<StompSession>
ConnectionHandlingStompSession. getSessionFuture()
Return a future that will complete when the session is ready for use.ListenableFuture<StompSession>
DefaultStompSession. getSessionFuture()
org.springframework.messaging.tcp中ListenableFuture的使用
返回ListenableFuture的org.springframework.messaging.tcp中的方法 修饰符和类型 方法 说明 ListenableFuture<Void>
TcpOperations. connect(TcpConnectionHandler<P> connectionHandler)
Open a new connection.ListenableFuture<Void>
TcpOperations. connect(TcpConnectionHandler<P> connectionHandler, ReconnectStrategy reconnectStrategy)
Open a new connection and a strategy for reconnecting if the connection fails.ListenableFuture<Void>
TcpConnection. send(Message<P> message)
Send the given message.ListenableFuture<Void>
TcpOperations. shutdown()
Shut down and close any open connections.org.springframework.messaging.tcp.reactor中ListenableFuture的使用
返回ListenableFuture的org.springframework.messaging.tcp.reactor中的方法 修饰符和类型 方法 说明 ListenableFuture<Void>
ReactorNettyTcpClient. connect(TcpConnectionHandler<P> handler)
ListenableFuture<Void>
ReactorNettyTcpClient. connect(TcpConnectionHandler<P> handler, ReconnectStrategy strategy)
ListenableFuture<Void>
ReactorNettyTcpConnection. send(Message<P> message)
ListenableFuture<Void>
ReactorNettyTcpClient. shutdown()
org.springframework.mock.http.client中ListenableFuture的使用
返回ListenableFuture的org.springframework.mock.http.client中的方法 修饰符和类型 方法 说明 ListenableFuture<ClientHttpResponse>
MockAsyncClientHttpRequest. executeAsync()
已过时。org.springframework.scheduling.annotation中ListenableFuture的使用
实现ListenableFuture的org.springframework.scheduling.annotation中的类 修饰符和类型 类 说明 class
AsyncResult<V>
A pass-throughFuture
handle that can be used for method signatures which are declared with aFuture
return type for asynchronous execution.返回ListenableFuture的org.springframework.scheduling.annotation中的方法 修饰符和类型 方法 说明 static <V> ListenableFuture<V>
AsyncResult. forExecutionException(Throwable ex)
Create a new async result which exposes the given exception as anExecutionException
fromFuture.get()
.static <V> ListenableFuture<V>
AsyncResult. forValue(V value)
Create a new async result which exposes the given value fromFuture.get()
.org.springframework.scheduling.commonj中ListenableFuture的使用
返回ListenableFuture的org.springframework.scheduling.commonj中的方法 修饰符和类型 方法 说明 ListenableFuture<?>
WorkManagerTaskExecutor. submitListenable(Runnable task)
已过时。<T> ListenableFuture<T>
WorkManagerTaskExecutor. submitListenable(Callable<T> task)
已过时。org.springframework.scheduling.concurrent中ListenableFuture的使用
返回ListenableFuture的org.springframework.scheduling.concurrent中的方法 修饰符和类型 方法 说明 ListenableFuture<?>
ConcurrentTaskExecutor. submitListenable(Runnable task)
<T> ListenableFuture<T>
ConcurrentTaskExecutor. submitListenable(Callable<T> task)
ListenableFuture<?>
ThreadPoolTaskExecutor. submitListenable(Runnable task)
<T> ListenableFuture<T>
ThreadPoolTaskExecutor. submitListenable(Callable<T> task)
ListenableFuture<?>
ThreadPoolTaskScheduler. submitListenable(Runnable task)
<T> ListenableFuture<T>
ThreadPoolTaskScheduler. submitListenable(Callable<T> task)
org.springframework.scheduling.quartz中ListenableFuture的使用
返回ListenableFuture的org.springframework.scheduling.quartz中的方法 修饰符和类型 方法 说明 ListenableFuture<?>
SimpleThreadPoolTaskExecutor. submitListenable(Runnable task)
<T> ListenableFuture<T>
SimpleThreadPoolTaskExecutor. submitListenable(Callable<T> task)
org.springframework.util.concurrent中ListenableFuture的使用
实现ListenableFuture的org.springframework.util.concurrent中的类 修饰符和类型 类 说明 class
CompletableToListenableFutureAdapter<T>
class
ListenableFutureAdapter<T,S>
Abstract class that adapts aListenableFuture
parameterized over S into aListenableFuture
parameterized over T.class
ListenableFutureTask<T>
Extension ofFutureTask
that implementsListenableFuture
.class
MonoToListenableFutureAdapter<T>
Adapts aMono
into aListenableFuture
.class
SettableListenableFuture<T>
AListenableFuture
whose value can be set viaSettableListenableFuture.set(Object)
orSettableListenableFuture.setException(Throwable)
.参数类型为ListenableFuture的org.springframework.util.concurrent中的构造器 构造器 说明 ListenableFutureAdapter(ListenableFuture<S> adaptee)
Construct a newListenableFutureAdapter
with the given adaptee.org.springframework.web.client中ListenableFuture的使用
返回ListenableFuture的org.springframework.web.client中的方法 修饰符和类型 方法 说明 ListenableFuture<?>
AsyncRestOperations. delete(String url, Object... uriVariables)
已过时。Asynchronously delete the resources at the specified URI.ListenableFuture<?>
AsyncRestOperations. delete(String url, Map<String,?> uriVariables)
已过时。Asynchronously delete the resources at the specified URI.ListenableFuture<?>
AsyncRestOperations. delete(URI url)
已过时。Asynchronously delete the resources at the specified URI.ListenableFuture<?>
AsyncRestTemplate. delete(String url, Object... uriVariables)
已过时。ListenableFuture<?>
AsyncRestTemplate. delete(String url, Map<String,?> uriVariables)
已过时。ListenableFuture<?>
AsyncRestTemplate. delete(URI url)
已过时。protected <T> ListenableFuture<T>
AsyncRestTemplate. doExecute(URI url, HttpMethod method, AsyncRequestCallback requestCallback, ResponseExtractor<T> responseExtractor)
已过时。Execute the given method on the provided URI.<T> ListenableFuture<ResponseEntity<T>>
AsyncRestOperations. exchange(String url, HttpMethod method, HttpEntity<?> requestEntity, Class<T> responseType, Object... uriVariables)
已过时。Asynchronously execute the HTTP method to the given URI template, writing the given request entity to the request, and returns the response asResponseEntity
.<T> ListenableFuture<ResponseEntity<T>>
AsyncRestOperations. exchange(String url, HttpMethod method, HttpEntity<?> requestEntity, Class<T> responseType, Map<String,?> uriVariables)
已过时。Asynchronously execute the HTTP method to the given URI template, writing the given request entity to the request, and returns the response asResponseEntity
.<T> ListenableFuture<ResponseEntity<T>>
AsyncRestOperations. exchange(String url, HttpMethod method, HttpEntity<?> requestEntity, ParameterizedTypeReference<T> responseType, Object... uriVariables)
已过时。Asynchronously execute the HTTP method to the given URI template, writing the given request entity to the request, and returns the response asResponseEntity
.<T> ListenableFuture<ResponseEntity<T>>
AsyncRestOperations. exchange(String url, HttpMethod method, HttpEntity<?> requestEntity, ParameterizedTypeReference<T> responseType, Map<String,?> uriVariables)
已过时。Asynchronously execute the HTTP method to the given URI template, writing the given request entity to the request, and returns the response asResponseEntity
.<T> ListenableFuture<ResponseEntity<T>>
AsyncRestOperations. exchange(URI url, HttpMethod method, HttpEntity<?> requestEntity, Class<T> responseType)
已过时。Asynchronously execute the HTTP method to the given URI template, writing the given request entity to the request, and returns the response asResponseEntity
.<T> ListenableFuture<ResponseEntity<T>>
AsyncRestOperations. exchange(URI url, HttpMethod method, HttpEntity<?> requestEntity, ParameterizedTypeReference<T> responseType)
已过时。Asynchronously execute the HTTP method to the given URI template, writing the given request entity to the request, and returns the response asResponseEntity
.<T> ListenableFuture<ResponseEntity<T>>
AsyncRestTemplate. exchange(String url, HttpMethod method, HttpEntity<?> requestEntity, Class<T> responseType, Object... uriVariables)
已过时。<T> ListenableFuture<ResponseEntity<T>>
AsyncRestTemplate. exchange(String url, HttpMethod method, HttpEntity<?> requestEntity, Class<T> responseType, Map<String,?> uriVariables)
已过时。<T> ListenableFuture<ResponseEntity<T>>
AsyncRestTemplate. exchange(String url, HttpMethod method, HttpEntity<?> requestEntity, ParameterizedTypeReference<T> responseType, Object... uriVariables)
已过时。<T> ListenableFuture<ResponseEntity<T>>
AsyncRestTemplate. exchange(String url, HttpMethod method, HttpEntity<?> requestEntity, ParameterizedTypeReference<T> responseType, Map<String,?> uriVariables)
已过时。<T> ListenableFuture<ResponseEntity<T>>
AsyncRestTemplate. exchange(URI url, HttpMethod method, HttpEntity<?> requestEntity, Class<T> responseType)
已过时。<T> ListenableFuture<ResponseEntity<T>>
AsyncRestTemplate. exchange(URI url, HttpMethod method, HttpEntity<?> requestEntity, ParameterizedTypeReference<T> responseType)
已过时。<T> ListenableFuture<T>
AsyncRestOperations. execute(String url, HttpMethod method, AsyncRequestCallback requestCallback, ResponseExtractor<T> responseExtractor, Object... uriVariables)
已过时。Asynchronously execute the HTTP method to the given URI template, preparing the request with theAsyncRequestCallback
, and reading the response with aResponseExtractor
.<T> ListenableFuture<T>
AsyncRestOperations. execute(String url, HttpMethod method, AsyncRequestCallback requestCallback, ResponseExtractor<T> responseExtractor, Map<String,?> uriVariables)
已过时。Asynchronously execute the HTTP method to the given URI template, preparing the request with theAsyncRequestCallback
, and reading the response with aResponseExtractor
.<T> ListenableFuture<T>
AsyncRestOperations. execute(URI url, HttpMethod method, AsyncRequestCallback requestCallback, ResponseExtractor<T> responseExtractor)
已过时。Asynchronously execute the HTTP method to the given URL, preparing the request with theAsyncRequestCallback
, and reading the response with aResponseExtractor
.<T> ListenableFuture<T>
AsyncRestTemplate. execute(String url, HttpMethod method, AsyncRequestCallback requestCallback, ResponseExtractor<T> responseExtractor, Object... uriVariables)
已过时。<T> ListenableFuture<T>
AsyncRestTemplate. execute(String url, HttpMethod method, AsyncRequestCallback requestCallback, ResponseExtractor<T> responseExtractor, Map<String,?> uriVariables)
已过时。<T> ListenableFuture<T>
AsyncRestTemplate. execute(URI url, HttpMethod method, AsyncRequestCallback requestCallback, ResponseExtractor<T> responseExtractor)
已过时。<T> ListenableFuture<ResponseEntity<T>>
AsyncRestOperations. getForEntity(String url, Class<T> responseType, Object... uriVariables)
已过时。Asynchronously retrieve an entity by doing a GET on the specified URL.<T> ListenableFuture<ResponseEntity<T>>
AsyncRestOperations. getForEntity(String url, Class<T> responseType, Map<String,?> uriVariables)
已过时。Asynchronously retrieve a representation by doing a GET on the URI template.<T> ListenableFuture<ResponseEntity<T>>
AsyncRestOperations. getForEntity(URI url, Class<T> responseType)
已过时。Asynchronously retrieve a representation by doing a GET on the URL.<T> ListenableFuture<ResponseEntity<T>>
AsyncRestTemplate. getForEntity(String url, Class<T> responseType, Object... uriVariables)
已过时。<T> ListenableFuture<ResponseEntity<T>>
AsyncRestTemplate. getForEntity(String url, Class<T> responseType, Map<String,?> uriVariables)
已过时。<T> ListenableFuture<ResponseEntity<T>>
AsyncRestTemplate. getForEntity(URI url, Class<T> responseType)
已过时。ListenableFuture<HttpHeaders>
AsyncRestOperations. headForHeaders(String url, Object... uriVariables)
已过时。Asynchronously retrieve all headers of the resource specified by the URI template.ListenableFuture<HttpHeaders>
AsyncRestOperations. headForHeaders(String url, Map<String,?> uriVariables)
已过时。Asynchronously retrieve all headers of the resource specified by the URI template.ListenableFuture<HttpHeaders>
AsyncRestOperations. headForHeaders(URI url)
已过时。Asynchronously retrieve all headers of the resource specified by the URL.ListenableFuture<HttpHeaders>
AsyncRestTemplate. headForHeaders(String url, Object... uriVariables)
已过时。ListenableFuture<HttpHeaders>
AsyncRestTemplate. headForHeaders(String url, Map<String,?> uriVariables)
已过时。ListenableFuture<HttpHeaders>
AsyncRestTemplate. headForHeaders(URI url)
已过时。ListenableFuture<Set<HttpMethod>>
AsyncRestOperations. optionsForAllow(String url, Object... uriVariables)
已过时。Asynchronously return the value of the Allow header for the given URI.ListenableFuture<Set<HttpMethod>>
AsyncRestOperations. optionsForAllow(String url, Map<String,?> uriVariables)
已过时。Asynchronously return the value of the Allow header for the given URI.ListenableFuture<Set<HttpMethod>>
AsyncRestOperations. optionsForAllow(URI url)
已过时。Asynchronously return the value of the Allow header for the given URL.ListenableFuture<Set<HttpMethod>>
AsyncRestTemplate. optionsForAllow(String url, Object... uriVars)
已过时。ListenableFuture<Set<HttpMethod>>
AsyncRestTemplate. optionsForAllow(String url, Map<String,?> uriVars)
已过时。ListenableFuture<Set<HttpMethod>>
AsyncRestTemplate. optionsForAllow(URI url)
已过时。<T> ListenableFuture<ResponseEntity<T>>
AsyncRestOperations. postForEntity(String url, HttpEntity<?> request, Class<T> responseType, Object... uriVariables)
已过时。Create a new resource by POSTing the given object to the URI template, and asynchronously returns the response asResponseEntity
.<T> ListenableFuture<ResponseEntity<T>>
AsyncRestOperations. postForEntity(String url, HttpEntity<?> request, Class<T> responseType, Map<String,?> uriVariables)
已过时。Create a new resource by POSTing the given object to the URI template, and asynchronously returns the response asResponseEntity
.<T> ListenableFuture<ResponseEntity<T>>
AsyncRestOperations. postForEntity(URI url, HttpEntity<?> request, Class<T> responseType)
已过时。Create a new resource by POSTing the given object to the URL, and asynchronously returns the response asResponseEntity
.<T> ListenableFuture<ResponseEntity<T>>
AsyncRestTemplate. postForEntity(String url, HttpEntity<?> request, Class<T> responseType, Object... uriVariables)
已过时。<T> ListenableFuture<ResponseEntity<T>>
AsyncRestTemplate. postForEntity(String url, HttpEntity<?> request, Class<T> responseType, Map<String,?> uriVariables)
已过时。<T> ListenableFuture<ResponseEntity<T>>
AsyncRestTemplate. postForEntity(URI url, HttpEntity<?> request, Class<T> responseType)
已过时。ListenableFuture<URI>
AsyncRestOperations. postForLocation(String url, HttpEntity<?> request, Object... uriVariables)
已过时。Create a new resource by POSTing the given object to the URI template, and asynchronously returns the value of theLocation
header.ListenableFuture<URI>
AsyncRestOperations. postForLocation(String url, HttpEntity<?> request, Map<String,?> uriVariables)
已过时。Create a new resource by POSTing the given object to the URI template, and asynchronously returns the value of theLocation
header.ListenableFuture<URI>
AsyncRestOperations. postForLocation(URI url, HttpEntity<?> request)
已过时。Create a new resource by POSTing the given object to the URL, and asynchronously returns the value of theLocation
header.ListenableFuture<URI>
AsyncRestTemplate. postForLocation(String url, HttpEntity<?> request, Object... uriVars)
已过时。ListenableFuture<URI>
AsyncRestTemplate. postForLocation(String url, HttpEntity<?> request, Map<String,?> uriVars)
已过时。ListenableFuture<URI>
AsyncRestTemplate. postForLocation(URI url, HttpEntity<?> request)
已过时。ListenableFuture<?>
AsyncRestOperations. put(String url, HttpEntity<?> request, Object... uriVariables)
已过时。Create or update a resource by PUTting the given object to the URI.ListenableFuture<?>
AsyncRestOperations. put(String url, HttpEntity<?> request, Map<String,?> uriVariables)
已过时。Creates a new resource by PUTting the given object to URI template.ListenableFuture<?>
AsyncRestOperations. put(URI url, HttpEntity<?> request)
已过时。Creates a new resource by PUTting the given object to URL.ListenableFuture<?>
AsyncRestTemplate. put(String url, HttpEntity<?> request, Object... uriVars)
已过时。ListenableFuture<?>
AsyncRestTemplate. put(String url, HttpEntity<?> request, Map<String,?> uriVars)
已过时。ListenableFuture<?>
AsyncRestTemplate. put(URI url, HttpEntity<?> request)
已过时。org.springframework.web.socket.client中ListenableFuture的使用
返回ListenableFuture的org.springframework.web.socket.client中的方法 修饰符和类型 方法 说明 ListenableFuture<WebSocketSession>
AbstractWebSocketClient. doHandshake(WebSocketHandler webSocketHandler, String uriTemplate, Object... uriVars)
ListenableFuture<WebSocketSession>
AbstractWebSocketClient. doHandshake(WebSocketHandler webSocketHandler, WebSocketHttpHeaders headers, URI uri)
ListenableFuture<WebSocketSession>
WebSocketClient. doHandshake(WebSocketHandler webSocketHandler, String uriTemplate, Object... uriVariables)
ListenableFuture<WebSocketSession>
WebSocketClient. doHandshake(WebSocketHandler webSocketHandler, WebSocketHttpHeaders headers, URI uri)
protected abstract ListenableFuture<WebSocketSession>
AbstractWebSocketClient. doHandshakeInternal(WebSocketHandler webSocketHandler, HttpHeaders headers, URI uri, List<String> subProtocols, List<WebSocketExtension> extensions, Map<String,Object> attributes)
Perform the actual handshake to establish a connection to the server.org.springframework.web.socket.client.jetty中ListenableFuture的使用
返回ListenableFuture的org.springframework.web.socket.client.jetty中的方法 修饰符和类型 方法 说明 ListenableFuture<WebSocketSession>
JettyWebSocketClient. doHandshake(WebSocketHandler webSocketHandler, String uriTemplate, Object... uriVars)
ListenableFuture<WebSocketSession>
JettyWebSocketClient. doHandshakeInternal(WebSocketHandler wsHandler, HttpHeaders headers, URI uri, List<String> protocols, List<WebSocketExtension> extensions, Map<String,Object> attributes)
org.springframework.web.socket.client.standard中ListenableFuture的使用
返回ListenableFuture的org.springframework.web.socket.client.standard中的方法 修饰符和类型 方法 说明 protected ListenableFuture<WebSocketSession>
StandardWebSocketClient. doHandshakeInternal(WebSocketHandler webSocketHandler, HttpHeaders headers, URI uri, List<String> protocols, List<WebSocketExtension> extensions, Map<String,Object> attributes)
org.springframework.web.socket.messaging中ListenableFuture的使用
返回ListenableFuture的org.springframework.web.socket.messaging中的方法 修饰符和类型 方法 说明 ListenableFuture<StompSession>
WebSocketStompClient. connect(String url, StompSessionHandler handler, Object... uriVars)
Connect to the given WebSocket URL and notify the givenStompSessionHandler
when connected on the STOMP level after the CONNECTED frame is received.ListenableFuture<StompSession>
WebSocketStompClient. connect(String url, WebSocketHttpHeaders handshakeHeaders, StompHeaders connectHeaders, StompSessionHandler handler, Object... uriVariables)
An overloaded version ofWebSocketStompClient.connect(String, StompSessionHandler, Object...)
that also acceptsWebSocketHttpHeaders
to use for the WebSocket handshake andStompHeaders
for the STOMP CONNECT frame.ListenableFuture<StompSession>
WebSocketStompClient. connect(String url, WebSocketHttpHeaders handshakeHeaders, StompSessionHandler handler, Object... uriVariables)
An overloaded version ofWebSocketStompClient.connect(String, StompSessionHandler, Object...)
that also acceptsWebSocketHttpHeaders
to use for the WebSocket handshake.ListenableFuture<StompSession>
WebSocketStompClient. connect(URI url, WebSocketHttpHeaders handshakeHeaders, StompHeaders connectHeaders, StompSessionHandler sessionHandler)
An overloaded version ofWebSocketStompClient.connect(String, WebSocketHttpHeaders, StompSessionHandler, Object...)
that accepts a fully preparedURI
.org.springframework.web.socket.sockjs.client中ListenableFuture的使用
返回ListenableFuture的org.springframework.web.socket.sockjs.client中的方法 修饰符和类型 方法 说明 ListenableFuture<WebSocketSession>
AbstractXhrTransport. connect(TransportRequest request, WebSocketHandler handler)
ListenableFuture<WebSocketSession>
Transport. connect(TransportRequest request, WebSocketHandler webSocketHandler)
Connect the transport.ListenableFuture<WebSocketSession>
WebSocketTransport. connect(TransportRequest request, WebSocketHandler handler)
ListenableFuture<WebSocketSession>
SockJsClient. doHandshake(WebSocketHandler handler, String uriTemplate, Object... uriVars)
ListenableFuture<WebSocketSession>
SockJsClient. doHandshake(WebSocketHandler handler, WebSocketHttpHeaders headers, URI url)