Package org.springframework.kafka.requestreply

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>>, ListenableFuture<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>

public class RequestReplyFuture<K,V,R>
extends SettableListenableFuture<org.apache.kafka.clients.consumer.ConsumerRecord<K,R>>

A listenable future for requests/replies.

Since:

2.1.3

Author:

Gary Russell

Constructor Summary

Constructors

Constructor	Description
RequestReplyFuture()

Method Summary

Modifier and Type	Method	Description
ListenableFuture<SendResult<K,V>>	getSendFuture()
protected void	setSendFuture(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(ListenableFuture<SendResult<K,V>> sendFuture)

getSendFuture

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