Uses of Interface
org.springframework.pulsar.reactive.core.ReactiveMessageConsumerBuilderCustomizer
Packages that use ReactiveMessageConsumerBuilderCustomizer
Package
Description
Package containing Spring configuration classes for the framework.
Package containing the core reactive components of the framework.
Package containing listener components for receiving Pulsar messages.
-
Uses of ReactiveMessageConsumerBuilderCustomizer in org.springframework.pulsar.reactive.config
Methods in org.springframework.pulsar.reactive.config with parameters of type ReactiveMessageConsumerBuilderCustomizerModifier and TypeMethodDescriptionvoidMethodReactivePulsarListenerEndpoint.setConsumerCustomizer(ReactiveMessageConsumerBuilderCustomizer<V> consumerCustomizer) -
Uses of ReactiveMessageConsumerBuilderCustomizer in org.springframework.pulsar.reactive.core
Method parameters in org.springframework.pulsar.reactive.core with type arguments of type ReactiveMessageConsumerBuilderCustomizerModifier and TypeMethodDescriptionorg.apache.pulsar.reactive.client.api.ReactiveMessageConsumer<T>DefaultReactivePulsarConsumerFactory.createConsumer(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageConsumerBuilderCustomizer<T>> customizers) org.apache.pulsar.reactive.client.api.ReactiveMessageConsumer<T>ReactivePulsarConsumerFactory.createConsumer(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageConsumerBuilderCustomizer<T>> customizers) Create a reactive message consumer. -
Uses of ReactiveMessageConsumerBuilderCustomizer in org.springframework.pulsar.reactive.listener
Methods in org.springframework.pulsar.reactive.listener that return ReactiveMessageConsumerBuilderCustomizerModifier and TypeMethodDescriptionDefaultReactivePulsarMessageListenerContainer.getConsumerCustomizer()Methods in org.springframework.pulsar.reactive.listener with parameters of type ReactiveMessageConsumerBuilderCustomizerModifier and TypeMethodDescriptionvoidDefaultReactivePulsarMessageListenerContainer.setConsumerCustomizer(ReactiveMessageConsumerBuilderCustomizer<T> consumerCustomizer) voidReactivePulsarMessageListenerContainer.setConsumerCustomizer(ReactiveMessageConsumerBuilderCustomizer<T> consumerCustomizer)