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:

java.util.concurrent.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

Author:

Gary Russell

Constructor Summary

Constructors

Constructor and Description
RequestReplyFuture()

Method Summary

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

RequestReplyFuture

public RequestReplyFuture()

Method Detail

setSendFuture

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

getSendFuture

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