Class RequestReplyTypedMessageFuture<K,V,P>
java.lang.Object
org.springframework.util.concurrent.SettableListenableFuture<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:
Future<Message<?>>,ListenableFuture<Message<?>>
A listenable future for
Message replies with a specific payload type.- Since:
- 2.7
- Author:
- Gary Russell
-
Method Summary
Methods inherited from class org.springframework.kafka.requestreply.RequestReplyMessageFuture
getSendFutureMethods inherited from class org.springframework.util.concurrent.SettableListenableFuture
addCallback, addCallback, cancel, completable, interruptTask, isCancelled, isDone, set, setException
-
Method Details
-
get
- Specified by:
getin interfaceFuture<K>- Overrides:
getin classSettableListenableFuture<Message<?>>- Throws:
InterruptedExceptionExecutionException
-
get
public Message<P> get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException - Specified by:
getin interfaceFuture<K>- Overrides:
getin classSettableListenableFuture<Message<?>>- Throws:
InterruptedExceptionExecutionExceptionTimeoutException
-