Class RequestReplyTypedMessageFuture<K,V,P>
java.lang.Object
java.util.concurrent.CompletableFuture<Message<?>>
org.springframework.kafka.requestreply.RequestReplyMessageFuture<K,V>
org.springframework.kafka.requestreply.RequestReplyTypedMessageFuture<K,V,P>
- Type Parameters:
K- the key type.V- the outbound data type.P- the reply payload type.
- All Implemented Interfaces:
CompletionStage<Message<?>>,Future<Message<?>>
A listenable future for
Message replies with a specific payload type.- Since:
- 2.7
- Author:
- Gary Russell
-
Nested Class Summary
Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture
CompletableFuture.AsynchronousCompletionTask -
Method Summary
Methods inherited from class org.springframework.kafka.requestreply.RequestReplyMessageFuture
getSendFutureMethods inherited from class java.util.concurrent.CompletableFuture
acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, complete, completeAsync, completeAsync, completedFuture, completedStage, completeExceptionally, completeOnTimeout, copy, defaultExecutor, delayedExecutor, delayedExecutor, exceptionally, exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, failedFuture, failedStage, 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 Details
-
get
- Specified by:
getin interfaceFuture<K>- Overrides:
getin classCompletableFuture<Message<?>>- Throws:
InterruptedExceptionExecutionException
-
get
public Message<P> get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException - Specified by:
getin interfaceFuture<K>- Overrides:
getin classCompletableFuture<Message<?>>- Throws:
InterruptedExceptionExecutionExceptionTimeoutException
-