Uses of Interface
org.springframework.util.concurrent.ListenableFuture
Package
Description
This package defines Spring's core TaskExecutor abstraction,
and provides SyncTaskExecutor and SimpleAsyncTaskExecutor implementations.
Support classes for Spring's TaskExecutor abstraction.
Common infrastructure for invoking message handler methods.
Generic support for simple messaging protocols (like STOMP).
Contains abstractions and implementation classes for establishing TCP connections via
TcpOperations
,
handling messages via
TcpConnectionHandler
,
as well as sending messages via
TcpConnection
.Contains support for TCP messaging based on Reactor.
Annotation support for asynchronous method execution.
Scheduling convenience classes for the
java.util.concurrent
and jakarta.enterprise.concurrent
packages, allowing to set up a
ThreadPoolExecutor or ScheduledThreadPoolExecutor as a bean in a Spring
context.Support classes for the open source scheduler
Quartz,
allowing to set up Quartz Schedulers, JobDetails and
Triggers as beans in a Spring context.
Useful generic
java.util.concurrent.Future
extensions.Client-side abstractions for WebSocket applications.
Client-side support for the Jetty WebSocket API.
Client-side classes for use with standard Java WebSocket endpoints.
WebSocket integration for Spring's messaging module.
SockJS client implementation of
WebSocketClient
.-
Uses of ListenableFuture in org.springframework.core.task
Modifier and TypeMethodDescriptionAsyncListenableTaskExecutor.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.SimpleAsyncTaskExecutor.submitListenable
(Runnable task) <T> ListenableFuture<T>
SimpleAsyncTaskExecutor.submitListenable
(Callable<T> task) -
Uses of ListenableFuture in org.springframework.core.task.support
Modifier and TypeMethodDescriptionTaskExecutorAdapter.submitListenable
(Runnable task) <T> ListenableFuture<T>
TaskExecutorAdapter.submitListenable
(Callable<T> task) -
Uses of ListenableFuture in org.springframework.messaging.handler.invocation
Modifier and TypeMethodDescriptionAsyncHandlerMethodReturnValueHandler.toListenableFuture
(Object returnValue, MethodParameter returnType) Adapt the asynchronous return value to aListenableFuture
.CompletableFutureReturnValueHandler.toListenableFuture
(Object returnValue, MethodParameter returnType) HandlerMethodReturnValueHandlerComposite.toListenableFuture
(Object returnValue, MethodParameter returnType) ListenableFutureReturnValueHandler.toListenableFuture
(Object returnValue, MethodParameter returnType) ReactiveReturnValueHandler.toListenableFuture
(Object returnValue, MethodParameter returnType) -
Uses of ListenableFuture in org.springframework.messaging.simp.stomp
Modifier and TypeMethodDescriptionReactorNettyTcpStompClient.connect
(StompHeaders connectHeaders, StompSessionHandler handler) An overloaded version ofReactorNettyTcpStompClient.connect(StompSessionHandler)
that accepts headers to use for the STOMP CONNECT frame.ReactorNettyTcpStompClient.connect
(StompSessionHandler handler) Connect and notify the givenStompSessionHandler
when connected on the STOMP level.ConnectionHandlingStompSession.getSessionFuture()
Return a future that will complete when the session is ready for use.DefaultStompSession.getSessionFuture()
-
Uses of ListenableFuture in org.springframework.messaging.tcp
Modifier and TypeMethodDescriptionTcpOperations.connect
(TcpConnectionHandler<P> connectionHandler) Open a new connection.TcpOperations.connect
(TcpConnectionHandler<P> connectionHandler, ReconnectStrategy reconnectStrategy) Open a new connection and a strategy for reconnecting if the connection fails.Send the given message.TcpOperations.shutdown()
Shut down and close any open connections. -
Uses of ListenableFuture in org.springframework.messaging.tcp.reactor
Modifier and TypeMethodDescriptionReactorNettyTcpClient.connect
(TcpConnectionHandler<P> handler) ReactorNettyTcpClient.connect
(TcpConnectionHandler<P> handler, ReconnectStrategy strategy) ReactorNettyTcpClient.shutdown()
-
Uses of ListenableFuture in org.springframework.scheduling.annotation
Modifier and TypeClassDescriptionclass
AsyncResult<V>
A pass-throughFuture
handle that can be used for method signatures which are declared with aFuture
return type for asynchronous execution.Modifier and TypeMethodDescriptionstatic <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()
. -
Uses of ListenableFuture in org.springframework.scheduling.concurrent
Modifier and TypeMethodDescriptionConcurrentTaskExecutor.submitListenable
(Runnable task) <T> ListenableFuture<T>
ConcurrentTaskExecutor.submitListenable
(Callable<T> task) ThreadPoolTaskExecutor.submitListenable
(Runnable task) <T> ListenableFuture<T>
ThreadPoolTaskExecutor.submitListenable
(Callable<T> task) ThreadPoolTaskScheduler.submitListenable
(Runnable task) <T> ListenableFuture<T>
ThreadPoolTaskScheduler.submitListenable
(Callable<T> task) -
Uses of ListenableFuture in org.springframework.scheduling.quartz
Modifier and TypeMethodDescriptionSimpleThreadPoolTaskExecutor.submitListenable
(Runnable task) <T> ListenableFuture<T>
SimpleThreadPoolTaskExecutor.submitListenable
(Callable<T> task) -
Uses of ListenableFuture in org.springframework.util.concurrent
Modifier and TypeClassDescriptionclass
class
Abstract class that adapts aListenableFuture
parameterized over S into aListenableFuture
parameterized over T.class
Extension ofFutureTask
that implementsListenableFuture
.class
Adapts aMono
into aListenableFuture
by obtaining aCompletableFuture
from theMono
viaMono.toFuture()
and then adapting it withCompletableToListenableFutureAdapter
.class
AListenableFuture
whose value can be set viaSettableListenableFuture.set(Object)
orSettableListenableFuture.setException(Throwable)
.ModifierConstructorDescriptionprotected
ListenableFutureAdapter
(ListenableFuture<S> adaptee) Construct a newListenableFutureAdapter
with the given adaptee. -
Uses of ListenableFuture in org.springframework.web.socket.client
Modifier and TypeMethodDescriptionAbstractWebSocketClient.doHandshake
(WebSocketHandler webSocketHandler, String uriTemplate, Object... uriVars) final ListenableFuture<WebSocketSession>
AbstractWebSocketClient.doHandshake
(WebSocketHandler webSocketHandler, WebSocketHttpHeaders headers, URI uri) WebSocketClient.doHandshake
(WebSocketHandler webSocketHandler, String uriTemplate, Object... uriVariables) 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. -
Uses of ListenableFuture in org.springframework.web.socket.client.jetty
Modifier and TypeMethodDescriptionJettyWebSocketClient.doHandshake
(WebSocketHandler webSocketHandler, String uriTemplate, Object... uriVars) JettyWebSocketClient.doHandshakeInternal
(WebSocketHandler wsHandler, HttpHeaders headers, URI uri, List<String> protocols, List<WebSocketExtension> extensions, Map<String, Object> attributes) -
Uses of ListenableFuture in org.springframework.web.socket.client.standard
Modifier and TypeMethodDescriptionprotected ListenableFuture<WebSocketSession>
StandardWebSocketClient.doHandshakeInternal
(WebSocketHandler webSocketHandler, HttpHeaders headers, URI uri, List<String> protocols, List<WebSocketExtension> extensions, Map<String, Object> attributes) -
Uses of ListenableFuture in org.springframework.web.socket.messaging
Modifier and TypeMethodDescriptionWebSocketStompClient.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.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.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.WebSocketStompClient.connect
(URI url, WebSocketHttpHeaders handshakeHeaders, StompHeaders connectHeaders, StompSessionHandler sessionHandler) An overloaded version ofWebSocketStompClient.connect(String, WebSocketHttpHeaders, StompSessionHandler, Object...)
that accepts a fully preparedURI
. -
Uses of ListenableFuture in org.springframework.web.socket.sockjs.client
Modifier and TypeMethodDescriptionAbstractXhrTransport.connect
(TransportRequest request, WebSocketHandler handler) Transport.connect
(TransportRequest request, WebSocketHandler webSocketHandler) Connect the transport.WebSocketTransport.connect
(TransportRequest request, WebSocketHandler handler) SockJsClient.doHandshake
(WebSocketHandler handler, String uriTemplate, Object... uriVars) final ListenableFuture<WebSocketSession>
SockJsClient.doHandshake
(WebSocketHandler handler, WebSocketHttpHeaders headers, URI url)