Class RequestReplyTypedMessageFuture.Completable
- java.lang.Object
-
- java.util.concurrent.CompletableFuture<org.springframework.messaging.Message<?>>
-
- org.springframework.kafka.requestreply.RequestReplyMessageFuture.Completable
-
- org.springframework.kafka.requestreply.RequestReplyTypedMessageFuture.Completable
-
- All Implemented Interfaces:
java.util.concurrent.CompletionStage<org.springframework.messaging.Message<?>>,java.util.concurrent.Future<org.springframework.messaging.Message<?>>
- Enclosing class:
- RequestReplyTypedMessageFuture<K,V,P>
public class RequestReplyTypedMessageFuture.Completable extends RequestReplyMessageFuture.Completable
ACompletableFutureversion.- Since:
- 2.9
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.springframework.messaging.Message<P>get()org.springframework.messaging.Message<P>get(long timeout, java.util.concurrent.TimeUnit unit)-
Methods inherited from class org.springframework.kafka.requestreply.RequestReplyMessageFuture.Completable
cancel, getSendFuture
-
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, 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
-
get
public org.springframework.messaging.Message<P> get() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
- Specified by:
getin interfacejava.util.concurrent.Future<org.springframework.messaging.Message<?>>- Overrides:
getin classjava.util.concurrent.CompletableFuture<org.springframework.messaging.Message<?>>- Throws:
java.lang.InterruptedExceptionjava.util.concurrent.ExecutionException
-
get
public org.springframework.messaging.Message<P> get(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, java.util.concurrent.TimeoutException
- Specified by:
getin interfacejava.util.concurrent.Future<org.springframework.messaging.Message<?>>- Overrides:
getin classjava.util.concurrent.CompletableFuture<org.springframework.messaging.Message<?>>- Throws:
java.lang.InterruptedExceptionjava.util.concurrent.ExecutionExceptionjava.util.concurrent.TimeoutException
-
-