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, toMessage
public 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)
MessagingMessageConverter
convertPayload
in class MessagingMessageConverter
message
- the message.protected java.lang.Object extractAndConvertValue(org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, java.lang.reflect.Type type)
MessagingMessageConverter
extractAndConvertValue
in class MessagingMessageConverter
record
- the record.type
- the required type.