Package org.springframework.pulsar.support.converter

Class PulsarRecordMessageConverter<V>

java.lang.Object
org.springframework.pulsar.support.converter.PulsarRecordMessageConverter<V>
Type Parameters:
V - message type
All Implemented Interfaces:
PulsarMessageConverter<V>, MessageConverter
public class PulsarRecordMessageConverter<V> extends Object implements PulsarMessageConverter<V>
A Messaging MessageConverter implementation for a message listener that receives individual messages.
Author:
Soby Chacko, Chris Bono

  • Constructor Details

    • PulsarRecordMessageConverter

      public PulsarRecordMessageConverter(PulsarHeaderMapper headerMapper)

  • 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 interface PulsarMessageConverter<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 interface PulsarMessageConverter<V>

    • getMessagingConverter

      protected MessageConverter getMessagingConverter()

    • setMessagingConverter

      public void setMessagingConverter(SmartMessageConverter messagingConverter)

    • extractAndConvertValue

      protected Object extractAndConvertValue(org.apache.pulsar.client.api.Message<V> record)