Class RequestReplyFuture<K,V,R>
java.lang.Object
org.springframework.util.concurrent.SettableListenableFuture<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>
org.springframework.kafka.requestreply.RequestReplyFuture<K,V,R>
- Type Parameters:
K- the key type.V- the outbound data type.R- the reply data type.
- All Implemented Interfaces:
Future<org.apache.kafka.clients.consumer.ConsumerRecord<K,,R>> org.springframework.util.concurrent.ListenableFuture<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>
public class RequestReplyFuture<K,V,R>
extends org.springframework.util.concurrent.SettableListenableFuture<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>
A listenable future for requests/replies.
- Since:
- 2.1.3
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> protected voidsetSendFuture(org.springframework.util.concurrent.ListenableFuture<SendResult<K, V>> sendFuture) Methods inherited from class org.springframework.util.concurrent.SettableListenableFuture
addCallback, addCallback, cancel, completable, get, get, interruptTask, isCancelled, isDone, set, setException
-
Constructor Details
-
RequestReplyFuture
public RequestReplyFuture()
-
-
Method Details
-
setSendFuture
protected void setSendFuture(org.springframework.util.concurrent.ListenableFuture<SendResult<K, V>> sendFuture) -
getSendFuture
-