public class ProjectingMessageConverter extends MessagingMessageConverter
MessageConverter implementation that uses a Spring Data
ProjectionFactory to bind incoming messages to projection interfaces.logger| Constructor and Description |
|---|
ProjectingMessageConverter(com.fasterxml.jackson.databind.ObjectMapper mapper)
Creates a new
ProjectingMessageConverter using the given ObjectMapper. |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Object |
convertPayload(org.springframework.messaging.Message<?> message)
Subclasses can convert the payload; by default, it's sent unchanged to Kafka.
|
protected java.lang.Object |
extractAndConvertValue(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record,
java.lang.reflect.Type type)
Subclasses can convert the value; by default, it's returned as provided by Kafka.
|
fromMessage, initialRecordHeaders, setGenerateMessageId, setGenerateTimestamp, setHeaderMapper, toMessageclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcommonHeaderspublic ProjectingMessageConverter(com.fasterxml.jackson.databind.ObjectMapper mapper)
ProjectingMessageConverter using the given ObjectMapper.mapper - must not be null.protected java.lang.Object convertPayload(org.springframework.messaging.Message<?> message)
MessagingMessageConverterconvertPayload in class MessagingMessageConvertermessage - the message.protected java.lang.Object extractAndConvertValue(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record,
java.lang.reflect.Type type)
MessagingMessageConverterextractAndConvertValue in class MessagingMessageConverterrecord - the record.type - the required type.