Class RequestReplyMessageFuture<K,V>
java.lang.Object
org.springframework.util.concurrent.SettableListenableFuture<org.springframework.messaging.Message<?>>
org.springframework.kafka.requestreply.RequestReplyMessageFuture<K,V>
- Type Parameters:
K- the key type.V- the outbound data type.
- All Implemented Interfaces:
Future<org.springframework.messaging.Message<?>>,org.springframework.util.concurrent.ListenableFuture<org.springframework.messaging.Message<?>>
- Direct Known Subclasses:
RequestReplyTypedMessageFuture
public class RequestReplyMessageFuture<K,V>
extends org.springframework.util.concurrent.SettableListenableFuture<org.springframework.messaging.Message<?>>
A listenable future for
Message replies.- Since:
- 2.7
-
Method Summary
Modifier and TypeMethodDescriptionorg.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> Return the send future.Methods inherited from class org.springframework.util.concurrent.SettableListenableFuture
addCallback, addCallback, cancel, completable, get, get, interruptTask, isCancelled, isDone, set, setException
-
Method Details
-
getSendFuture
Return the send future.- Returns:
- the send future.
-