Interface PulsarRecordMessageConverter<T>

Type Parameters:
T - message type
All Superinterfaces:
MessageConverter
All Known Implementing Classes:
PulsarMessagingMessageConverter

public interface PulsarRecordMessageConverter<T> extends MessageConverter
Pulsar specific record converter strategy.
Author:
Soby Chacko
  • Method Summary

    Modifier and Type
    Method
    Description
    fromMessage(Message<?> message, String defaultTopic)
     
    toMessage(org.apache.pulsar.client.api.Message<T> record, org.apache.pulsar.client.api.Consumer<T> consumer, Type payloadType)
     
  • Method Details

    • toMessage

      Message<?> toMessage(org.apache.pulsar.client.api.Message<T> record, org.apache.pulsar.client.api.Consumer<T> consumer, Type payloadType)
    • fromMessage

      T fromMessage(Message<?> message, String defaultTopic)