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 aRunnabletask for execution, receiving aListenableFuturerepresenting that task.<T> ListenableFuture<T>AsyncListenableTaskExecutor.submitListenable(Callable<T> task) Submit aCallabletask for execution, receiving aListenableFuturerepresenting 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 givenStompSessionHandlerwhen 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 TypeClassDescriptionclassAsyncResult<V>A pass-throughFuturehandle that can be used for method signatures which are declared with aFuturereturn 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 anExecutionExceptionfromFuture.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 TypeClassDescriptionclassclassAbstract class that adapts aListenableFutureparameterized over S into aListenableFutureparameterized over T.classExtension ofFutureTaskthat implementsListenableFuture.classAdapts aMonointo aListenableFutureby obtaining aCompletableFuturefrom theMonoviaMono.toFuture()and then adapting it withCompletableToListenableFutureAdapter.classAListenableFuturewhose value can be set viaSettableListenableFuture.set(Object)orSettableListenableFuture.setException(Throwable).Constructors in org.springframework.util.concurrent with parameters of type ListenableFutureModifierConstructorDescriptionprotectedListenableFutureAdapter(ListenableFuture<S> adaptee) Construct a newListenableFutureAdapterwith 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 givenStompSessionHandlerwhen 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 acceptsWebSocketHttpHeadersto use for the WebSocket handshake andStompHeadersfor the STOMP CONNECT frame.WebSocketStompClient.connect(String url, WebSocketHttpHeaders handshakeHeaders, StompSessionHandler handler, Object... uriVariables) An overloaded version ofWebSocketStompClient.connect(String, StompSessionHandler, Object...)that also acceptsWebSocketHttpHeadersto 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)