Package org.springframework.kafka.requestreply

Class RequestReplyMessageFuture<K,V>

java.lang.Object

org.springframework.util.concurrent.SettableListenableFuture<Message<?>>

org.springframework.kafka.requestreply.RequestReplyMessageFuture<K,V>

Type Parameters:

K - the key type.

V - the outbound data type.

All Implemented Interfaces:

Future<Message<?>>, ListenableFuture<Message<?>>

Direct Known Subclasses:

RequestReplyTypedMessageFuture

public class RequestReplyMessageFuture<K,V>
extends SettableListenableFuture<Message<?>>

A listenable future for Message replies.

Since:

2.7

Author:

Gary Russell

Method Summary

Modifier and Type	Method	Description
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

Method Details

getSendFuture

public ListenableFuture<SendResult<K,V>> getSendFuture()

Return the send future.

Returns:

the send future.