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 Type
    Method
    Description
    org.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

    Methods inherited from class java.lang.Object

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

    • getSendFuture

      public org.springframework.util.concurrent.ListenableFuture<SendResult<K,V>> getSendFuture()
      Return the send future.
      Returns:
      the send future.