| Package | Description |
|---|---|
| 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 via
TcpOperations,
handling messages via
TcpConnectionHandler,
as well as sending messages via
TcpConnection. |
| 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 the
java.util.concurrent
and javax.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 generic
java.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 of
WebSocketClient. |
| Modifier and Type | Method and Description |
|---|---|
<T> ListenableFuture<T> |
AsyncListenableTaskExecutor.submitListenable(Callable<T> task)
Submit a
Callable task for execution, receiving a ListenableFuture
representing that task. |
<T> ListenableFuture<T> |
SimpleAsyncTaskExecutor.submitListenable(Callable<T> task) |
ListenableFuture<?> |
AsyncListenableTaskExecutor.submitListenable(Runnable task)
Submit a
Runnable task for execution, receiving a ListenableFuture
representing that task. |
ListenableFuture<?> |
SimpleAsyncTaskExecutor.submitListenable(Runnable task) |
| Modifier and Type | Method and Description |
|---|---|
<T> ListenableFuture<T> |
TaskExecutorAdapter.submitListenable(Callable<T> task) |
ListenableFuture<?> |
TaskExecutorAdapter.submitListenable(Runnable task) |
| Modifier and Type | Method and Description |
|---|---|
ListenableFuture<ClientHttpResponse> |
AsyncClientHttpRequest.executeAsync()
Deprecated.
Execute this request asynchronously, resulting in a Future handle.
|
ListenableFuture<ClientHttpResponse> |
AsyncClientHttpRequestExecution.executeAsync(HttpRequest request,
byte[] body)
Deprecated.
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)
Deprecated.
Intercept the given request, and return a response future.
|
| Modifier and Type | Method and Description |
|---|---|
<T> ListenableFuture<T> |
WorkManagerTaskExecutor.submitListenable(Callable<T> task) |
ListenableFuture<?> |
WorkManagerTaskExecutor.submitListenable(Runnable task) |
| Modifier and Type | Method and Description |
|---|---|
ListenableFuture<?> |
CompletableFutureReturnValueHandler.toListenableFuture(Object returnValue,
MethodParameter returnType) |
ListenableFuture<?> |
AsyncHandlerMethodReturnValueHandler.toListenableFuture(Object returnValue,
MethodParameter returnType)
Adapt the asynchronous return value to a
ListenableFuture. |
ListenableFuture<?> |
ReactiveReturnValueHandler.toListenableFuture(Object returnValue,
MethodParameter returnType) |
ListenableFuture<?> |
ListenableFutureReturnValueHandler.toListenableFuture(Object returnValue,
MethodParameter returnType) |
ListenableFuture<?> |
HandlerMethodReturnValueHandlerComposite.toListenableFuture(Object returnValue,
MethodParameter returnType) |
| Modifier and Type | Method and Description |
|---|---|
ListenableFuture<StompSession> |
ReactorNettyTcpStompClient.connect(StompHeaders connectHeaders,
StompSessionHandler handler)
An overloaded version of
ReactorNettyTcpStompClient.connect(StompSessionHandler) that
accepts headers to use for the STOMP CONNECT frame. |
ListenableFuture<StompSession> |
ReactorNettyTcpStompClient.connect(StompSessionHandler handler)
Connect and notify the given
StompSessionHandler when connected
on the STOMP level. |
ListenableFuture<StompSession> |
DefaultStompSession.getSessionFuture() |
ListenableFuture<StompSession> |
ConnectionHandlingStompSession.getSessionFuture()
Return a future that will complete when the session is ready for use.
|
| Modifier and Type | Method and Description |
|---|---|
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.
|
| Modifier and Type | Method and Description |
|---|---|
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() |
| Modifier and Type | Method and Description |
|---|---|
ListenableFuture<ClientHttpResponse> |
MockAsyncClientHttpRequest.executeAsync()
Deprecated.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AsyncResult<V>
A pass-through
Future handle that can be used for method signatures
which are declared with a Future return type for asynchronous execution. |
| Modifier and Type | Method and Description |
|---|---|
static <V> ListenableFuture<V> |
AsyncResult.forExecutionException(Throwable ex)
Create a new async result which exposes the given exception as an
ExecutionException from Future.get(). |
static <V> ListenableFuture<V> |
AsyncResult.forValue(V value)
Create a new async result which exposes the given value from
Future.get(). |
| Modifier and Type | Method and Description |
|---|---|
<T> ListenableFuture<T> |
WorkManagerTaskExecutor.submitListenable(Callable<T> task)
Deprecated.
|
ListenableFuture<?> |
WorkManagerTaskExecutor.submitListenable(Runnable task)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
<T> ListenableFuture<T> |
ThreadPoolTaskScheduler.submitListenable(Callable<T> task) |
<T> ListenableFuture<T> |
ThreadPoolTaskExecutor.submitListenable(Callable<T> task) |
<T> ListenableFuture<T> |
ConcurrentTaskExecutor.submitListenable(Callable<T> task) |
ListenableFuture<?> |
ThreadPoolTaskScheduler.submitListenable(Runnable task) |
ListenableFuture<?> |
ThreadPoolTaskExecutor.submitListenable(Runnable task) |
ListenableFuture<?> |
ConcurrentTaskExecutor.submitListenable(Runnable task) |
| Modifier and Type | Method and Description |
|---|---|
<T> ListenableFuture<T> |
SimpleThreadPoolTaskExecutor.submitListenable(Callable<T> task) |
ListenableFuture<?> |
SimpleThreadPoolTaskExecutor.submitListenable(Runnable task) |
| Modifier and Type | Class and Description |
|---|---|
class |
CompletableToListenableFutureAdapter<T>
|
class |
ListenableFutureAdapter<T,S>
Abstract class that adapts a
ListenableFuture parameterized over S into a
ListenableFuture parameterized over T. |
class |
ListenableFutureTask<T>
Extension of
FutureTask that implements ListenableFuture. |
class |
MonoToListenableFutureAdapter<T>
Adapts a
Mono into a ListenableFuture by obtaining a
CompletableFuture from the Mono via Mono.toFuture()
and then adapting it with CompletableToListenableFutureAdapter. |
class |
SettableListenableFuture<T>
A
ListenableFuture whose value can be set via SettableListenableFuture.set(Object)
or SettableListenableFuture.setException(Throwable). |
| Constructor and Description |
|---|
ListenableFutureAdapter(ListenableFuture<S> adaptee)
Construct a new
ListenableFutureAdapter with the given adaptee. |
| Modifier and Type | Method and Description |
|---|---|
ListenableFuture<?> |
AsyncRestOperations.delete(String url,
Map<String,?> uriVariables)
Deprecated.
Asynchronously delete the resources at the specified URI.
|
ListenableFuture<?> |
AsyncRestTemplate.delete(String url,
Map<String,?> uriVariables)
Deprecated.
|
ListenableFuture<?> |
AsyncRestOperations.delete(String url,
Object... uriVariables)
Deprecated.
Asynchronously delete the resources at the specified URI.
|
ListenableFuture<?> |
AsyncRestTemplate.delete(String url,
Object... uriVariables)
Deprecated.
|
ListenableFuture<?> |
AsyncRestOperations.delete(URI url)
Deprecated.
Asynchronously delete the resources at the specified URI.
|
ListenableFuture<?> |
AsyncRestTemplate.delete(URI url)
Deprecated.
|
protected <T> ListenableFuture<T> |
AsyncRestTemplate.doExecute(URI url,
HttpMethod method,
AsyncRequestCallback requestCallback,
ResponseExtractor<T> responseExtractor)
Deprecated.
Execute the given method on the provided URI.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestOperations.exchange(String url,
HttpMethod method,
HttpEntity<?> requestEntity,
Class<T> responseType,
Map<String,?> uriVariables)
Deprecated.
Asynchronously execute the HTTP method to the given URI template, writing the
given request entity to the request, and returns the response as
ResponseEntity. |
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestTemplate.exchange(String url,
HttpMethod method,
HttpEntity<?> requestEntity,
Class<T> responseType,
Map<String,?> uriVariables)
Deprecated.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestOperations.exchange(String url,
HttpMethod method,
HttpEntity<?> requestEntity,
Class<T> responseType,
Object... uriVariables)
Deprecated.
Asynchronously execute the HTTP method to the given URI template, writing the
given request entity to the request, and returns the response as
ResponseEntity. |
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestTemplate.exchange(String url,
HttpMethod method,
HttpEntity<?> requestEntity,
Class<T> responseType,
Object... uriVariables)
Deprecated.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestOperations.exchange(String url,
HttpMethod method,
HttpEntity<?> requestEntity,
ParameterizedTypeReference<T> responseType,
Map<String,?> uriVariables)
Deprecated.
Asynchronously execute the HTTP method to the given URI template, writing the given
request entity to the request, and returns the response as
ResponseEntity. |
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestTemplate.exchange(String url,
HttpMethod method,
HttpEntity<?> requestEntity,
ParameterizedTypeReference<T> responseType,
Map<String,?> uriVariables)
Deprecated.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestOperations.exchange(String url,
HttpMethod method,
HttpEntity<?> requestEntity,
ParameterizedTypeReference<T> responseType,
Object... uriVariables)
Deprecated.
Asynchronously execute the HTTP method to the given URI template, writing the given
request entity to the request, and returns the response as
ResponseEntity. |
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestTemplate.exchange(String url,
HttpMethod method,
HttpEntity<?> requestEntity,
ParameterizedTypeReference<T> responseType,
Object... uriVariables)
Deprecated.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestOperations.exchange(URI url,
HttpMethod method,
HttpEntity<?> requestEntity,
Class<T> responseType)
Deprecated.
Asynchronously execute the HTTP method to the given URI template, writing the
given request entity to the request, and returns the response as
ResponseEntity. |
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestTemplate.exchange(URI url,
HttpMethod method,
HttpEntity<?> requestEntity,
Class<T> responseType)
Deprecated.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestOperations.exchange(URI url,
HttpMethod method,
HttpEntity<?> requestEntity,
ParameterizedTypeReference<T> responseType)
Deprecated.
Asynchronously execute the HTTP method to the given URI template, writing the given
request entity to the request, and returns the response as
ResponseEntity. |
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestTemplate.exchange(URI url,
HttpMethod method,
HttpEntity<?> requestEntity,
ParameterizedTypeReference<T> responseType)
Deprecated.
|
<T> ListenableFuture<T> |
AsyncRestOperations.execute(String url,
HttpMethod method,
AsyncRequestCallback requestCallback,
ResponseExtractor<T> responseExtractor,
Map<String,?> uriVariables)
Deprecated.
Asynchronously execute the HTTP method to the given URI template, preparing the
request with the
AsyncRequestCallback, and reading the response with a
ResponseExtractor. |
<T> ListenableFuture<T> |
AsyncRestTemplate.execute(String url,
HttpMethod method,
AsyncRequestCallback requestCallback,
ResponseExtractor<T> responseExtractor,
Map<String,?> uriVariables)
Deprecated.
|
<T> ListenableFuture<T> |
AsyncRestOperations.execute(String url,
HttpMethod method,
AsyncRequestCallback requestCallback,
ResponseExtractor<T> responseExtractor,
Object... uriVariables)
Deprecated.
Asynchronously execute the HTTP method to the given URI template, preparing the
request with the
AsyncRequestCallback, and reading the response with a
ResponseExtractor. |
<T> ListenableFuture<T> |
AsyncRestTemplate.execute(String url,
HttpMethod method,
AsyncRequestCallback requestCallback,
ResponseExtractor<T> responseExtractor,
Object... uriVariables)
Deprecated.
|
<T> ListenableFuture<T> |
AsyncRestOperations.execute(URI url,
HttpMethod method,
AsyncRequestCallback requestCallback,
ResponseExtractor<T> responseExtractor)
Deprecated.
Asynchronously execute the HTTP method to the given URL, preparing the request
with the
AsyncRequestCallback, and reading the response with a
ResponseExtractor. |
<T> ListenableFuture<T> |
AsyncRestTemplate.execute(URI url,
HttpMethod method,
AsyncRequestCallback requestCallback,
ResponseExtractor<T> responseExtractor)
Deprecated.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestOperations.getForEntity(String url,
Class<T> responseType,
Map<String,?> uriVariables)
Deprecated.
Asynchronously retrieve a representation by doing a GET on the URI template.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestTemplate.getForEntity(String url,
Class<T> responseType,
Map<String,?> uriVariables)
Deprecated.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestOperations.getForEntity(String url,
Class<T> responseType,
Object... uriVariables)
Deprecated.
Asynchronously retrieve an entity by doing a GET on the specified URL.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestTemplate.getForEntity(String url,
Class<T> responseType,
Object... uriVariables)
Deprecated.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestOperations.getForEntity(URI url,
Class<T> responseType)
Deprecated.
Asynchronously retrieve a representation by doing a GET on the URL.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestTemplate.getForEntity(URI url,
Class<T> responseType)
Deprecated.
|
ListenableFuture<HttpHeaders> |
AsyncRestOperations.headForHeaders(String url,
Map<String,?> uriVariables)
Deprecated.
Asynchronously retrieve all headers of the resource specified by the URI template.
|
ListenableFuture<HttpHeaders> |
AsyncRestTemplate.headForHeaders(String url,
Map<String,?> uriVariables)
Deprecated.
|
ListenableFuture<HttpHeaders> |
AsyncRestOperations.headForHeaders(String url,
Object... uriVariables)
Deprecated.
Asynchronously retrieve all headers of the resource specified by the URI template.
|
ListenableFuture<HttpHeaders> |
AsyncRestTemplate.headForHeaders(String url,
Object... uriVariables)
Deprecated.
|
ListenableFuture<HttpHeaders> |
AsyncRestOperations.headForHeaders(URI url)
Deprecated.
Asynchronously retrieve all headers of the resource specified by the URL.
|
ListenableFuture<HttpHeaders> |
AsyncRestTemplate.headForHeaders(URI url)
Deprecated.
|
ListenableFuture<Set<HttpMethod>> |
AsyncRestOperations.optionsForAllow(String url,
Map<String,?> uriVariables)
Deprecated.
Asynchronously return the value of the Allow header for the given URI.
|
ListenableFuture<Set<HttpMethod>> |
AsyncRestTemplate.optionsForAllow(String url,
Map<String,?> uriVars)
Deprecated.
|
ListenableFuture<Set<HttpMethod>> |
AsyncRestOperations.optionsForAllow(String url,
Object... uriVariables)
Deprecated.
Asynchronously return the value of the Allow header for the given URI.
|
ListenableFuture<Set<HttpMethod>> |
AsyncRestTemplate.optionsForAllow(String url,
Object... uriVars)
Deprecated.
|
ListenableFuture<Set<HttpMethod>> |
AsyncRestOperations.optionsForAllow(URI url)
Deprecated.
Asynchronously return the value of the Allow header for the given URL.
|
ListenableFuture<Set<HttpMethod>> |
AsyncRestTemplate.optionsForAllow(URI url)
Deprecated.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestOperations.postForEntity(String url,
HttpEntity<?> request,
Class<T> responseType,
Map<String,?> uriVariables)
Deprecated.
Create a new resource by POSTing the given object to the URI template,
and asynchronously returns the response as
ResponseEntity. |
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestTemplate.postForEntity(String url,
HttpEntity<?> request,
Class<T> responseType,
Map<String,?> uriVariables)
Deprecated.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestOperations.postForEntity(String url,
HttpEntity<?> request,
Class<T> responseType,
Object... uriVariables)
Deprecated.
Create a new resource by POSTing the given object to the URI template,
and asynchronously returns the response as
ResponseEntity. |
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestTemplate.postForEntity(String url,
HttpEntity<?> request,
Class<T> responseType,
Object... uriVariables)
Deprecated.
|
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestOperations.postForEntity(URI url,
HttpEntity<?> request,
Class<T> responseType)
Deprecated.
Create a new resource by POSTing the given object to the URL,
and asynchronously returns the response as
ResponseEntity. |
<T> ListenableFuture<ResponseEntity<T>> |
AsyncRestTemplate.postForEntity(URI url,
HttpEntity<?> request,
Class<T> responseType)
Deprecated.
|
ListenableFuture<URI> |
AsyncRestOperations.postForLocation(String url,
HttpEntity<?> request,
Map<String,?> uriVariables)
Deprecated.
Create a new resource by POSTing the given object to the URI template, and
asynchronously returns the value of the
Location header. |
ListenableFuture<URI> |
AsyncRestTemplate.postForLocation(String url,
HttpEntity<?> request,
Map<String,?> uriVars)
Deprecated.
|
ListenableFuture<URI> |
AsyncRestOperations.postForLocation(String url,
HttpEntity<?> request,
Object... uriVariables)
Deprecated.
Create a new resource by POSTing the given object to the URI template, and
asynchronously returns the value of the
Location header. |
ListenableFuture<URI> |
AsyncRestTemplate.postForLocation(String url,
HttpEntity<?> request,
Object... uriVars)
Deprecated.
|
ListenableFuture<URI> |
AsyncRestOperations.postForLocation(URI url,
HttpEntity<?> request)
Deprecated.
Create a new resource by POSTing the given object to the URL, and asynchronously
returns the value of the
Location header. |
ListenableFuture<URI> |
AsyncRestTemplate.postForLocation(URI url,
HttpEntity<?> request)
Deprecated.
|
ListenableFuture<?> |
AsyncRestOperations.put(String url,
HttpEntity<?> request,
Map<String,?> uriVariables)
Deprecated.
Creates a new resource by PUTting the given object to URI template.
|
ListenableFuture<?> |
AsyncRestTemplate.put(String url,
HttpEntity<?> request,
Map<String,?> uriVars)
Deprecated.
|
ListenableFuture<?> |
AsyncRestOperations.put(String url,
HttpEntity<?> request,
Object... uriVariables)
Deprecated.
Create or update a resource by PUTting the given object to the URI.
|
ListenableFuture<?> |
AsyncRestTemplate.put(String url,
HttpEntity<?> request,
Object... uriVars)
Deprecated.
|
ListenableFuture<?> |
AsyncRestOperations.put(URI url,
HttpEntity<?> request)
Deprecated.
Creates a new resource by PUTting the given object to URL.
|
ListenableFuture<?> |
AsyncRestTemplate.put(URI url,
HttpEntity<?> request)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
ListenableFuture<WebSocketSession> |
WebSocketClient.doHandshake(WebSocketHandler webSocketHandler,
String uriTemplate,
Object... uriVariables) |
ListenableFuture<WebSocketSession> |
AbstractWebSocketClient.doHandshake(WebSocketHandler webSocketHandler,
String uriTemplate,
Object... uriVars) |
ListenableFuture<WebSocketSession> |
WebSocketClient.doHandshake(WebSocketHandler webSocketHandler,
WebSocketHttpHeaders headers,
URI uri) |
ListenableFuture<WebSocketSession> |
AbstractWebSocketClient.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.
|
| Modifier and Type | Method and Description |
|---|---|
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) |
| Modifier and Type | Method and Description |
|---|---|
protected ListenableFuture<WebSocketSession> |
StandardWebSocketClient.doHandshakeInternal(WebSocketHandler webSocketHandler,
HttpHeaders headers,
URI uri,
List<String> protocols,
List<WebSocketExtension> extensions,
Map<String,Object> attributes) |
| Modifier and Type | Method and Description |
|---|---|
ListenableFuture<StompSession> |
WebSocketStompClient.connect(String url,
StompSessionHandler handler,
Object... uriVars)
Connect to the given WebSocket URL and notify the given
StompSessionHandler
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 of
WebSocketStompClient.connect(String, StompSessionHandler, Object...) that also accepts
WebSocketHttpHeaders to use for the WebSocket handshake and
StompHeaders for the STOMP CONNECT frame. |
ListenableFuture<StompSession> |
WebSocketStompClient.connect(String url,
WebSocketHttpHeaders handshakeHeaders,
StompSessionHandler handler,
Object... uriVariables)
An overloaded version of
WebSocketStompClient.connect(String, StompSessionHandler, Object...) that also
accepts WebSocketHttpHeaders to use for the WebSocket handshake. |
ListenableFuture<StompSession> |
WebSocketStompClient.connect(URI url,
WebSocketHttpHeaders handshakeHeaders,
StompHeaders connectHeaders,
StompSessionHandler sessionHandler)
An overloaded version of
WebSocketStompClient.connect(String, WebSocketHttpHeaders, StompSessionHandler, Object...)
that accepts a fully prepared URI. |
| Modifier and Type | Method and Description |
|---|---|
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) |