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 forMessage
replies with a specific payload type.- Since:
- 2.7
- Author:
- Gary Russell
-
-
Method Summary
All Methods Instance Methods Concrete Methods 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
-
-
-
-
Method Detail
-
get
public org.springframework.messaging.Message<P> get() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
- Specified by:
get
in interfacejava.util.concurrent.Future<K>
- Overrides:
get
in classorg.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 interfacejava.util.concurrent.Future<K>
- Overrides:
get
in classorg.springframework.util.concurrent.SettableListenableFuture<org.springframework.messaging.Message<?>>
- Throws:
java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.util.concurrent.TimeoutException
-
-