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
    Constructor
    Description
     
  • Method Summary

    Modifier and Type
    Method
    Description
    org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>>
     
    protected void
    setSendFuture(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

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Constructor Details

    • RequestReplyFuture

      public RequestReplyFuture()
  • Method Details

    • setSendFuture

      protected void setSendFuture(org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> sendFuture)
    • getSendFuture

      public org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> getSendFuture()