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 that return ReactiveMessageConsumerBuilderCustomizerMethods in org.springframework.pulsar.reactive.config with parameters of type ReactiveMessageConsumerBuilderCustomizerModifier and TypeMethodDescriptionvoid
MethodReactivePulsarListenerEndpoint.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.Constructor parameters in org.springframework.pulsar.reactive.core with type arguments of type ReactiveMessageConsumerBuilderCustomizerModifierConstructorDescriptionDefaultReactivePulsarConsumerFactory
(org.apache.pulsar.reactive.client.api.ReactivePulsarClient reactivePulsarClient, List<ReactiveMessageConsumerBuilderCustomizer<T>> defaultConfigCustomizers) Construct an instance. -
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 TypeMethodDescriptionvoid
DefaultReactivePulsarMessageListenerContainer.setConsumerCustomizer
(ReactiveMessageConsumerBuilderCustomizer<T> consumerCustomizer) void
ReactivePulsarMessageListenerContainer.setConsumerCustomizer
(ReactiveMessageConsumerBuilderCustomizer<T> consumerCustomizer)