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()
Create a new
ProjectingMessageConverter using a
JacksonUtils.enhancedObjectMapper() by default. |
ProjectingMessageConverter(MessagingMessageConverter delegate)
Create a new
ProjectingMessageConverter using the given ObjectMapper. |
ProjectingMessageConverter(com.fasterxml.jackson.databind.ObjectMapper mapper)
Create a new
ProjectingMessageConverter using the given ObjectMapper. |
ProjectingMessageConverter(com.fasterxml.jackson.databind.ObjectMapper mapper,
MessagingMessageConverter delegate)
Create 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, waitcommonHeaders, getGroupIdpublic ProjectingMessageConverter()
ProjectingMessageConverter using a
JacksonUtils.enhancedObjectMapper() by default.public ProjectingMessageConverter(com.fasterxml.jackson.databind.ObjectMapper mapper)
ProjectingMessageConverter using the given ObjectMapper.mapper - must not be null.public ProjectingMessageConverter(MessagingMessageConverter delegate)
ProjectingMessageConverter using the given ObjectMapper.delegate - the delegate converter for outbound and non-interfaces.public ProjectingMessageConverter(com.fasterxml.jackson.databind.ObjectMapper mapper,
MessagingMessageConverter delegate)
ProjectingMessageConverter using the given ObjectMapper.mapper - must not be null.delegate - the delegate converter for outbound and non-interfaces.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.