Class PulsarMessagingMessageConverter<V>
java.lang.Object
org.springframework.pulsar.support.converter.PulsarMessagingMessageConverter<V>
- Type Parameters:
V
- message type
- All Implemented Interfaces:
PulsarRecordMessageConverter<V>
,MessageConverter
public class PulsarMessagingMessageConverter<V>
extends Object
implements PulsarRecordMessageConverter<V>
A Messaging
MessageConverter
implementation
for a message listener that receives individual messages.- Author:
- Soby Chacko
-
Constructor Summary
ConstructorsConstructorDescriptionPulsarMessagingMessageConverter
(PulsarMessageHeaderMapper pulsarMessageHeaderMapper) -
Method Summary
Modifier and TypeMethodDescriptionprotected Object
extractAndConvertValue
(org.apache.pulsar.client.api.Message<V> record) fromMessage
(Message<?> messageArg, String defaultTopic) 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)
-
Constructor Details
-
PulsarMessagingMessageConverter
-
-
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 interfacePulsarRecordMessageConverter<V>
-
fromMessage
- Specified by:
fromMessage
in interfacePulsarRecordMessageConverter<V>
-
getMessagingConverter
-
setMessagingConverter
-
extractAndConvertValue
-