Uses of Interface
org.springframework.pulsar.reactive.core.ReactivePulsarConsumerFactory
Packages that use ReactivePulsarConsumerFactory
Package
Description
Package containing the Spring Boot
AutoConfiguration for the Spring for
Apache Pulsar framework.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 ReactivePulsarConsumerFactory in org.springframework.pulsar.autoconfigure
Methods in org.springframework.pulsar.autoconfigure that return ReactivePulsarConsumerFactoryModifier and TypeMethodDescriptionPulsarReactiveAutoConfiguration.reactivePulsarConsumerFactory(org.apache.pulsar.reactive.client.api.ReactivePulsarClient pulsarReactivePulsarClient) -
Uses of ReactivePulsarConsumerFactory in org.springframework.pulsar.reactive.config
Methods in org.springframework.pulsar.reactive.config that return ReactivePulsarConsumerFactoryModifier and TypeMethodDescriptionprotected ReactivePulsarConsumerFactory<T>DefaultReactivePulsarListenerContainerFactory.getConsumerFactory()Constructors in org.springframework.pulsar.reactive.config with parameters of type ReactivePulsarConsumerFactoryModifierConstructorDescriptionDefaultReactivePulsarListenerContainerFactory(ReactivePulsarConsumerFactory<T> consumerFactory, ReactivePulsarContainerProperties<T> containerProperties) -
Uses of ReactivePulsarConsumerFactory in org.springframework.pulsar.reactive.core
Classes in org.springframework.pulsar.reactive.core that implement ReactivePulsarConsumerFactory -
Uses of ReactivePulsarConsumerFactory in org.springframework.pulsar.reactive.listener
Methods in org.springframework.pulsar.reactive.listener that return ReactivePulsarConsumerFactoryModifier and TypeMethodDescriptionDefaultReactivePulsarMessageListenerContainer.getReactivePulsarConsumerFactory()Constructors in org.springframework.pulsar.reactive.listener with parameters of type ReactivePulsarConsumerFactoryModifierConstructorDescriptionDefaultReactivePulsarMessageListenerContainer(ReactivePulsarConsumerFactory<T> pulsarConsumerFactory, ReactivePulsarContainerProperties<T> pulsarContainerProperties)