Package org.springframework.kafka.requestreply

Class RequestReplyTypedMessageFuture<K,V,P>

java.lang.Object

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

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

org.springframework.kafka.requestreply.RequestReplyTypedMessageFuture<K,V,P>

Type Parameters:

K - the key type.

V - the outbound data type.

P - the reply payload type.

All Implemented Interfaces:

java.util.concurrent.Future<org.springframework.messaging.Message<?>>, org.springframework.util.concurrent.ListenableFuture<org.springframework.messaging.Message<?>>

public class RequestReplyTypedMessageFuture<K,V,P>
extends RequestReplyMessageFuture<K,V>

A listenable future for Message replies with a specific payload type.

Since:

2.7

Author:

Gary Russell

Method Summary

Modifier and Type	Method	Description
org.springframework.messaging.Message<P>	get()
org.springframework.messaging.Message<P>	get(long timeout, java.util.concurrent.TimeUnit unit)

Methods inherited from class org.springframework.kafka.requestreply.RequestReplyMessageFuture

getSendFuture

Methods inherited from class org.springframework.util.concurrent.SettableListenableFuture

addCallback, addCallback, cancel, completable, interruptTask, isCancelled, isDone, set, setException

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

get

public org.springframework.messaging.Message<P> get()
                                             throws java.lang.InterruptedException,
                                                    java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<K>

Overrides:

get in class org.springframework.util.concurrent.SettableListenableFuture<org.springframework.messaging.Message<?>>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public org.springframework.messaging.Message<P> get(long timeout,
                                                    java.util.concurrent.TimeUnit unit)
                                             throws java.lang.InterruptedException,
                                                    java.util.concurrent.ExecutionException,
                                                    java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<K>

Overrides:

get in class org.springframework.util.concurrent.SettableListenableFuture<org.springframework.messaging.Message<?>>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException