Uses of Interface
org.springframework.pulsar.reactive.core.ReactiveMessageReaderBuilderCustomizer
Packages that use ReactiveMessageReaderBuilderCustomizer
Package
Description
Package containing the core reactive components of the framework.
-
Uses of ReactiveMessageReaderBuilderCustomizer in org.springframework.pulsar.reactive.core
Method parameters in org.springframework.pulsar.reactive.core with type arguments of type ReactiveMessageReaderBuilderCustomizerModifier and TypeMethodDescriptionorg.apache.pulsar.reactive.client.api.ReactiveMessageReader<T>
DefaultReactivePulsarReaderFactory.createReader
(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageReaderBuilderCustomizer<T>> customizers) org.apache.pulsar.reactive.client.api.ReactiveMessageReader<T>
ReactivePulsarReaderFactory.createReader
(org.apache.pulsar.client.api.Schema<T> schema, List<ReactiveMessageReaderBuilderCustomizer<T>> customizers) Create a reactive message reader.Constructor parameters in org.springframework.pulsar.reactive.core with type arguments of type ReactiveMessageReaderBuilderCustomizerModifierConstructorDescriptionDefaultReactivePulsarReaderFactory
(org.apache.pulsar.reactive.client.api.ReactivePulsarClient reactivePulsarClient, List<ReactiveMessageReaderBuilderCustomizer<T>> defaultConfigCustomizers) Construct an instance.