Package org.springframework.pulsar.reactive.core

Interface ReactiveMessageConsumerBuilderCustomizer<T>

Type Parameters:
T - The message payload type
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface ReactiveMessageConsumerBuilderCustomizer<T>
Callback interface that can be implemented to customize the builder that is used by the ReactivePulsarConsumerFactory to create consumers.

When using Spring Boot autoconfiguration, any beans implementing this interface will be used as default configuration by the DefaultReactivePulsarConsumerFactory and as such will apply to all created consumers.

The consumer factory also supports passing in a specific instance of this callback when creating a consumer and as such the passed in customizer only applies to the single created consumer.

Author:
Christophe Bornet

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    customize(org.apache.pulsar.reactive.client.api.ReactiveMessageConsumerBuilder<T> reactiveMessageConsumerBuilder)
    Customize the ReactiveMessageConsumerBuilder.

  • Method Details

    • customize

      void customize(org.apache.pulsar.reactive.client.api.ReactiveMessageConsumerBuilder<T> reactiveMessageConsumerBuilder)
      Customize the ReactiveMessageConsumerBuilder.
      Parameters:
      reactiveMessageConsumerBuilder - the builder to customize