Class PulsarRecordMessageConverter<V>
java.lang.Object
org.springframework.pulsar.support.converter.PulsarRecordMessageConverter<V>
- Type Parameters:
V
- message type
- All Implemented Interfaces:
PulsarMessageConverter<V>
,MessageConverter
A Messaging
MessageConverter
implementation
for a message listener that receives individual messages.- Author:
- Soby Chacko, Chris Bono
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected Object
extractAndConvertValue
(org.apache.pulsar.client.api.Message<V> record) protected MessageConverter
void
setMessagingConverter
(SmartMessageConverter messagingConverter) Message<?>
toMessage
(org.apache.pulsar.client.api.Message<V> record, org.apache.pulsar.client.api.Consumer<V> consumer, Type type) Message<?>
toMessageFromReader
(org.apache.pulsar.client.api.Message<V> record, org.apache.pulsar.client.api.Reader<V> reader, Type payloadType)
-
Constructor Details
-
PulsarRecordMessageConverter
-
-
Method Details
-
toMessage
public Message<?> toMessage(org.apache.pulsar.client.api.Message<V> record, org.apache.pulsar.client.api.Consumer<V> consumer, Type type) - Specified by:
toMessage
in interfacePulsarMessageConverter<V>
-
toMessageFromReader
public Message<?> toMessageFromReader(org.apache.pulsar.client.api.Message<V> record, org.apache.pulsar.client.api.Reader<V> reader, Type payloadType) - Specified by:
toMessageFromReader
in interfacePulsarMessageConverter<V>
-
getMessagingConverter
-
setMessagingConverter
-
extractAndConvertValue
-