Package org.springframework.kafka.requestreply

Class RequestReplyMessageFuture<K,​V>

  • Type Parameters:
    K - the key type.
    V - the outbound data type.
    All Implemented Interfaces:
    java.util.concurrent.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
    Author:
    Gary Russell

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      RequestReplyMessageFuture.Completable asCompletable()
      Return a CompletableFuture representation of this instance.
      org.springframework.util.concurrent.ListenableFuture<SendResult<K,​V>> getSendFuture()
      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

    • Field Detail

      • sendFuture

        protected final org.springframework.util.concurrent.ListenableFuture<SendResult<K,​V>> sendFuture

      • completableSendFuture

        protected java.util.concurrent.CompletableFuture<SendResult<K,​V>> completableSendFuture

    • Method Detail

      • getSendFuture

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