Class RequestReplyMessageFuture<K,V>

java.lang.Object

java.util.concurrent.CompletableFuture<org.springframework.messaging.Message<?>>

org.springframework.kafka.requestreply.RequestReplyMessageFuture<K,V>

Type Parameters:

K - the key type.

V - the outbound data type.

All Implemented Interfaces:

CompletionStage<org.springframework.messaging.Message<?>>, Future<org.springframework.messaging.Message<?>>

Direct Known Subclasses:

RequestReplyTypedMessageFuture

public class RequestReplyMessageFuture<K,V>
extends CompletableFuture<org.springframework.messaging.Message<?>>

A listenable future for Message replies.

Since:

2.7

Nested Class Summary

Nested classes/interfaces inherited from class CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Nested classes/interfaces inherited from interface Future

Future.State

Method Summary

Modifier and Type	Method	Description
@Nullable CompletableFuture<SendResult<K,V>>	getSendFuture()	Return the send future.

Methods inherited from class 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, exceptionNow, failedFuture, failedStage, get, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, resultNow, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, state, 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

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Details

getSendFuture

public @Nullable CompletableFuture<SendResult<K,V>> getSendFuture()

Return the send future.

Returns:

the send future.