Uses of Interface
org.springframework.util.concurrent.ListenableFuture
Packages that use 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.
Java 5 annotation 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
Methods in org.springframework.core.task that return ListenableFutureModifier 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
Methods in org.springframework.core.task.support that return ListenableFutureModifier and TypeMethodDescriptionTaskExecutorAdapter.submitListenable
(Runnable task) <T> ListenableFuture<T>
TaskExecutorAdapter.submitListenable
(Callable<T> task) -
Uses of ListenableFuture in org.springframework.messaging.handler.invocation
Methods in org.springframework.messaging.handler.invocation that return ListenableFutureModifier 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
Methods in org.springframework.messaging.simp.stomp that return ListenableFutureModifier 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
Methods in org.springframework.messaging.tcp that return ListenableFutureModifier 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
Methods in org.springframework.messaging.tcp.reactor that return ListenableFutureModifier and TypeMethodDescriptionReactorNettyTcpClient.connect
(TcpConnectionHandler<P> handler) ReactorNettyTcpClient.connect
(TcpConnectionHandler<P> handler, ReconnectStrategy strategy) ReactorNettyTcpClient.shutdown()
-
Uses of ListenableFuture in org.springframework.scheduling.annotation
Classes in org.springframework.scheduling.annotation that implement ListenableFutureModifier 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.Methods in org.springframework.scheduling.annotation that return ListenableFutureModifier 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
Methods in org.springframework.scheduling.concurrent that return ListenableFutureModifier 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
Methods in org.springframework.scheduling.quartz that return ListenableFutureModifier and TypeMethodDescriptionSimpleThreadPoolTaskExecutor.submitListenable
(Runnable task) <T> ListenableFuture<T>
SimpleThreadPoolTaskExecutor.submitListenable
(Callable<T> task) -
Uses of ListenableFuture in org.springframework.util.concurrent
Classes in org.springframework.util.concurrent that implement ListenableFutureModifier 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)
.Constructors in org.springframework.util.concurrent with parameters of type ListenableFutureModifierConstructorDescriptionprotected
ListenableFutureAdapter
(ListenableFuture<S> adaptee) Construct a newListenableFutureAdapter
with the given adaptee. -
Uses of ListenableFuture in org.springframework.web.socket.client
Methods in org.springframework.web.socket.client that return ListenableFutureModifier 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
Methods in org.springframework.web.socket.client.jetty that return ListenableFutureModifier 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
Methods in org.springframework.web.socket.client.standard that return ListenableFutureModifier 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
Methods in org.springframework.web.socket.messaging that return ListenableFutureModifier 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
Methods in org.springframework.web.socket.sockjs.client that return ListenableFutureModifier 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)