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
getSendFuture
Methods inherited from class org.springframework.util.concurrent.SettableListenableFuture
addCallback, addCallback, cancel, completable, interruptTask, isCancelled, isDone, set, setException
-
Method Details
-
get
- Specified by:
get
in interfaceFuture<K>
- Overrides:
get
in classSettableListenableFuture<Message<?>>
- Throws:
InterruptedException
ExecutionException
-
get
public Message<P> get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException - Specified by:
get
in interfaceFuture<K>
- Overrides:
get
in classSettableListenableFuture<Message<?>>
- Throws:
InterruptedException
ExecutionException
TimeoutException
-