Package org.springframework.pulsar.core

Interface ConsumerBuilderCustomizer<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 ConsumerBuilderCustomizer<T>
Callback interface that can be implemented to customize the ConsumerBuilder that is used by the PulsarConsumerFactory to create consumers.

When using Spring Boot autoconfiguration, any beans implementing this interface will be used as default configuration by the DefaultPulsarConsumerFactory 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.client.api.ConsumerBuilder<T> consumerBuilder)
    Customize the ConsumerBuilder.

  • Method Details

    • customize

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