Package org.springframework.pulsar.reactive.core

Interface ReactivePulsarConsumerFactory<T>

Type Parameters:
T - payload type for the consumer.
All Known Implementing Classes:
DefaultReactivePulsarConsumerFactory
public interface ReactivePulsarConsumerFactory<T>
Pulsar reactive consumer factory interface.
Author:
Christophe Bornet

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.pulsar.reactive.client.api.ReactiveMessageConsumer<T>
    createConsumer(org.apache.pulsar.client.api.Schema<T> schema)
    Create a reactive message consumer.
    org.apache.pulsar.reactive.client.api.ReactiveMessageConsumer<T>
    createConsumer(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageConsumerBuilderCustomizer<T>> customizers)
    Create a reactive message consumer.

  • Method Details

    • createConsumer

      org.apache.pulsar.reactive.client.api.ReactiveMessageConsumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema)
      Create a reactive message consumer.
      Parameters:
      schema - the schema of the messages to be consumed
      Returns:
      the reactive message consumer

    • createConsumer

      org.apache.pulsar.reactive.client.api.ReactiveMessageConsumer<T> createConsumer(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageConsumerBuilderCustomizer<T>> customizers)
      Create a reactive message consumer.
      Parameters:
      schema - the schema of the messages to be consumed
      customizers - the optional list of customizers to apply to the reactive message consumer builder
      Returns:
      the reactive message consumer