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.
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
-
Method Details
-
customize
void customize(org.apache.pulsar.reactive.client.api.ReactiveMessageConsumerBuilder<T> reactiveMessageConsumerBuilder) Customize theReactiveMessageConsumerBuilder
.- Parameters:
reactiveMessageConsumerBuilder
- the builder to customize
-