Class RequestReplyTypedMessageFuture<K,V,P>
- java.lang.Object
-
- org.springframework.util.concurrent.SettableListenableFuture<org.springframework.messaging.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:
java.util.concurrent.Future<org.springframework.messaging.Message<?>>,org.springframework.util.concurrent.ListenableFuture<org.springframework.messaging.Message<?>>
public class RequestReplyTypedMessageFuture<K,V,P> extends RequestReplyMessageFuture<K,V>
A listenable future forMessagereplies with a specific payload type.- Since:
- 2.7
- Author:
- Gary Russell
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description classRequestReplyTypedMessageFuture.CompletableACompletableFutureversion.
-
Field Summary
-
Fields inherited from class org.springframework.kafka.requestreply.RequestReplyMessageFuture
completableSendFuture, sendFuture
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RequestReplyTypedMessageFuture.CompletableasCompletable()Return aCompletableFuturerepresentation of this instance.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
getSendFuture
-
-
-
-
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<K>- Overrides:
getin classorg.springframework.util.concurrent.SettableListenableFuture<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<K>- Overrides:
getin classorg.springframework.util.concurrent.SettableListenableFuture<org.springframework.messaging.Message<?>>- Throws:
java.lang.InterruptedExceptionjava.util.concurrent.ExecutionExceptionjava.util.concurrent.TimeoutException
-
asCompletable
public RequestReplyTypedMessageFuture.Completable asCompletable()
Description copied from class:RequestReplyMessageFutureReturn aCompletableFuturerepresentation of this instance.- Overrides:
asCompletablein classRequestReplyMessageFuture<K,V>- Returns:
- the
CompletableFuture.
-
-