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
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected ObjectextractAndConvertValue(org.apache.pulsar.client.api.Message<V> record) protected MessageConvertervoidsetMessagingConverter(SmartMessageConverter messagingConverter) Message<?>toMessage(org.apache.pulsar.client.api.Message<V> record, org.apache.pulsar.client.api.Consumer<V> consumer, Type type) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.springframework.pulsar.support.converter.PulsarMessageConverter
toMessageFromReader
-
Constructor Details
-
PulsarRecordMessageConverter
-
-
Method Details