Class RequestReplyMessageFuture.Completable
- java.lang.Object
-
- java.util.concurrent.CompletableFuture<org.springframework.messaging.Message<?>>
-
- org.springframework.kafka.requestreply.RequestReplyMessageFuture.Completable
-
- All Implemented Interfaces:
java.util.concurrent.CompletionStage<org.springframework.messaging.Message<?>>,java.util.concurrent.Future<org.springframework.messaging.Message<?>>
- Direct Known Subclasses:
RequestReplyTypedMessageFuture.Completable
- Enclosing class:
- RequestReplyMessageFuture<K,V>
public class RequestReplyMessageFuture.Completable extends java.util.concurrent.CompletableFuture<org.springframework.messaging.Message<?>>ACompletableFutureversion.- Since:
- 2.9
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleancancel(boolean mayInterruptIfRunning)java.util.concurrent.CompletableFuture<SendResult<K,V>>getSendFuture()Return the send future as aCompletableFuture.-
Methods inherited from class java.util.concurrent.CompletableFuture
acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, complete, completeAsync, completeAsync, completedFuture, completedStage, completeExceptionally, completeOnTimeout, copy, defaultExecutor, delayedExecutor, delayedExecutor, exceptionally, failedFuture, failedStage, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, supplyAsync, supplyAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, whenComplete, whenCompleteAsync, whenCompleteAsync
-
-
-
-
Method Detail
-
getSendFuture
public java.util.concurrent.CompletableFuture<SendResult<K,V>> getSendFuture()
Return the send future as aCompletableFuture.- Returns:
- the send future.
-
cancel
public boolean cancel(boolean mayInterruptIfRunning)
- Specified by:
cancelin interfacejava.util.concurrent.Future<org.springframework.messaging.Message<?>>- Overrides:
cancelin classjava.util.concurrent.CompletableFuture<org.springframework.messaging.Message<?>>
-
-