Package org.springframework.kafka.requestreply

Class RequestReplyTypedMessageFuture<K,V,P>

java.lang.Object

java.util.concurrent.CompletableFuture<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<Message<?>>, Future<Message<?>>

public class RequestReplyTypedMessageFuture<K,V,P>
extends RequestReplyMessageFuture<K,V>

A listenable future for Message replies with a specific payload type.

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
Message<P>	get()
Message<P>	get(long timeout, TimeUnit unit)

Methods inherited from class org.springframework.kafka.requestreply.RequestReplyMessageFuture

getSendFuture

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

get

public Message<P> get()
               throws InterruptedException,
ExecutionException

Specified by:

get in interface Future<K>

Overrides:

get in class CompletableFuture<Message<?>>

Throws:

InterruptedException

ExecutionException

get

public Message<P> get(long timeout,
 TimeUnit unit)
               throws InterruptedException,
ExecutionException,
TimeoutException

Specified by:

get in interface Future<K>

Overrides:

get in class CompletableFuture<Message<?>>

Throws:

InterruptedException

ExecutionException

TimeoutException