Package org.springframework.pulsar.support.converter

Interface PulsarMessageConverter<T>

Type Parameters:
T - message type
All Superinterfaces:
MessageConverter
All Known Implementing Classes:
PulsarRecordMessageConverter
public interface PulsarMessageConverter<T> extends MessageConverter
Pulsar specific record converter strategy.
Author:
Soby Chacko

  • Method Summary

    Modifier and Type
    Method
    Description
    Message<?>
    toMessage(org.apache.pulsar.client.api.Message<T> record, org.apache.pulsar.client.api.Consumer<T> consumer, Type payloadType)
     
    default Message<?>
    toMessageFromReader(org.apache.pulsar.client.api.Message<T> record, org.apache.pulsar.client.api.Reader<T> reader, 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)

    • toMessageFromReader

      default Message<?> toMessageFromReader(org.apache.pulsar.client.api.Message<T> record, org.apache.pulsar.client.api.Reader<T> reader, Type payloadType)