Package org.springframework.pulsar.reactive.core

Interface ReactivePulsarReaderFactory<T>

Type Parameters:
T - reactive message reader payload type
All Known Implementing Classes:
DefaultReactivePulsarReaderFactory
public interface ReactivePulsarReaderFactory<T>
The strategy to create a ReactiveMessageReader instance(s).
Author:
Christophe Bornet

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.pulsar.reactive.client.api.ReactiveMessageReader<T>
    createReader(org.apache.pulsar.client.api.Schema<T> schema)
    Create a reactive message reader.
    org.apache.pulsar.reactive.client.api.ReactiveMessageReader<T>
    createReader(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageReaderBuilderCustomizer<T>> customizers)
    Create a reactive message reader.

  • Method Details

    • createReader

      org.apache.pulsar.reactive.client.api.ReactiveMessageReader<T> createReader(org.apache.pulsar.client.api.Schema<T> schema)
      Create a reactive message reader.
      Parameters:
      schema - the schema of the messages to be read
      Returns:
      the reactive message reader

    • createReader

      org.apache.pulsar.reactive.client.api.ReactiveMessageReader<T> createReader(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageReaderBuilderCustomizer<T>> customizers)
      Create a reactive message reader.
      Parameters:
      schema - the schema of the messages to be read
      customizers - the optional list of readers to apply to the reactive message reader builder
      Returns:
      the reactive message reader