Class RequestReplyTypedMessageFuture<K,V,P>
java.lang.Object
java.util.concurrent.CompletableFuture<org.springframework.messaging.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<org.springframework.messaging.Message<?>>,Future<org.springframework.messaging.Message<?>>
A listenable future for
Message replies with a specific payload type.- Since:
- 2.7
-
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
public org.springframework.messaging.Message<P> get() throws InterruptedException, ExecutionException- Specified by:
getin interfaceFuture<K>- Overrides:
getin classCompletableFuture<org.springframework.messaging.Message<?>>- Throws:
InterruptedExceptionExecutionException
-
get
public org.springframework.messaging.Message<P> get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException - Specified by:
getin interfaceFuture<K>- Overrides:
getin classCompletableFuture<org.springframework.messaging.Message<?>>- Throws:
InterruptedExceptionExecutionExceptionTimeoutException
-