Package org.springframework.kafka.requestreply

Class RequestReplyMessageFuture<K,V>

java.lang.Object

java.util.concurrent.CompletableFuture<Message<?>>

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

Type Parameters:

K - the key type.

V - the outbound data type.

All Implemented Interfaces:

CompletionStage<Message<?>>, Future<Message<?>>

Direct Known Subclasses:

RequestReplyTypedMessageFuture

public class RequestReplyMessageFuture<K,V>
extends CompletableFuture<Message<?>>

A listenable future for Message replies.

Since:

2.7

Author:

Gary Russell

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Method Summary

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

Methods 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, 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

Methods inherited from class java.lang.Object

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

Method Details

getSendFuture

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

Return the send future.

Returns:

the send future.