Uses of Class
org.springframework.kafka.requestreply.RequestReplyMessageFuture
Package
Description
Provides classes for request/reply semantics.
-
Uses of RequestReplyMessageFuture in org.springframework.kafka.requestreply
Modifier and TypeClassDescriptionclass
A listenable future forMessage
replies with a specific payload type.Modifier and TypeMethodDescriptiondefault RequestReplyMessageFuture<K,
V> ReplyingKafkaOperations.sendAndReceive
(Message<?> message) Send a request message and receive a reply message with the default timeout.default RequestReplyMessageFuture<K,
V> ReplyingKafkaOperations.sendAndReceive
(Message<?> message, Duration replyTimeout) Send a request message and receive a reply message.ReplyingKafkaTemplate.sendAndReceive
(Message<?> message) ReplyingKafkaTemplate.sendAndReceive
(Message<?> message, Duration replyTimeout)