Package org.springframework.kafka.requestreply

Class RequestReplyFuture<K,V,R>

java.lang.Object

java.util.concurrent.CompletableFuture<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>

org.springframework.kafka.requestreply.RequestReplyFuture<K,V,R>

Type Parameters:

K - the key type.

V - the outbound data type.

R - the reply data type.

All Implemented Interfaces:

CompletionStage<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>, Future<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>

public class RequestReplyFuture<K,V,R>
extends CompletableFuture<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>

A CompletableFuture for requests/replies.

Since:

2.1.3

Author:

Gary Russell

Nested Class Summary

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

CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors

Constructor	Description
RequestReplyFuture()

Method Summary

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

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

Constructor Details

RequestReplyFuture

public RequestReplyFuture()

Method Details

setSendFuture

protected void setSendFuture(CompletableFuture<SendResult<K,V>> sendFuture)

getSendFuture

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

Return the send future.

Returns:

the send future.