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:
Future<org.springframework.messaging.Message<?>>,org.springframework.util.concurrent.ListenableFuture<org.springframework.messaging.Message<?>>
A listenable future for
Message replies with a specific payload type.- Since:
- 2.7
-
Method Summary
Methods inherited from class org.springframework.kafka.requestreply.RequestReplyMessageFuture
getSendFutureMethods inherited from class org.springframework.util.concurrent.SettableListenableFuture
addCallback, addCallback, cancel, completable, interruptTask, isCancelled, isDone, set, setException
-
Method Details
-
get
public org.springframework.messaging.Message<P> get() throws InterruptedException, ExecutionException- Specified by:
getin interfaceFuture<K>- Overrides:
getin classorg.springframework.util.concurrent.SettableListenableFuture<org.springframework.messaging.Message<?>>- Throws:
InterruptedExceptionExecutionException
-
get
public org.springframework.messaging.Message<P> get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException - Specified by:
getin interfaceFuture<K>- Overrides:
getin classorg.springframework.util.concurrent.SettableListenableFuture<org.springframework.messaging.Message<?>>- Throws:
InterruptedExceptionExecutionExceptionTimeoutException
-