Uses of Interface
org.springframework.pulsar.core.PulsarConsumerFactory
Packages that use PulsarConsumerFactory
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 components of the framework.
Package containing listener components for receiving Pulsar messages.
Package containing Spring Cloud Stream binder classes for Apache Pulsar.
-
Uses of PulsarConsumerFactory in org.springframework.pulsar.autoconfigure
Methods in org.springframework.pulsar.autoconfigure that return PulsarConsumerFactoryModifier and TypeMethodDescriptionPulsarAutoConfiguration.pulsarConsumerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient) -
Uses of PulsarConsumerFactory in org.springframework.pulsar.config
Methods in org.springframework.pulsar.config that return PulsarConsumerFactoryModifier and TypeMethodDescriptionprotected PulsarConsumerFactory<? super T>AbstractPulsarListenerContainerFactory.getConsumerFactory()Constructors in org.springframework.pulsar.config with parameters of type PulsarConsumerFactoryModifierConstructorDescriptionprotectedAbstractPulsarListenerContainerFactory(PulsarConsumerFactory<? super T> consumerFactory, PulsarContainerProperties containerProperties, io.micrometer.observation.ObservationRegistry observationRegistry) ConcurrentPulsarListenerContainerFactory(PulsarConsumerFactory<? super T> consumerFactory, PulsarContainerProperties containerProperties, io.micrometer.observation.ObservationRegistry observationRegistry) -
Uses of PulsarConsumerFactory in org.springframework.pulsar.core
Classes in org.springframework.pulsar.core that implement PulsarConsumerFactory -
Uses of PulsarConsumerFactory in org.springframework.pulsar.listener
Methods in org.springframework.pulsar.listener that return PulsarConsumerFactoryModifier and TypeMethodDescriptionAbstractPulsarMessageListenerContainer.getPulsarConsumerFactory()Constructors in org.springframework.pulsar.listener with parameters of type PulsarConsumerFactoryModifierConstructorDescriptionprotectedAbstractPulsarMessageListenerContainer(PulsarConsumerFactory<? super T> pulsarConsumerFactory, PulsarContainerProperties pulsarContainerProperties, io.micrometer.observation.ObservationRegistry observationRegistry) ConcurrentPulsarMessageListenerContainer(PulsarConsumerFactory<? super T> pulsarConsumerFactory, PulsarContainerProperties pulsarContainerProperties, io.micrometer.observation.ObservationRegistry observationRegistry) DefaultPulsarMessageListenerContainer(PulsarConsumerFactory<? super T> pulsarConsumerFactory, PulsarContainerProperties pulsarContainerProperties) DefaultPulsarMessageListenerContainer(PulsarConsumerFactory<? super T> pulsarConsumerFactory, PulsarContainerProperties pulsarContainerProperties, io.micrometer.observation.ObservationRegistry observationRegistry) -
Uses of PulsarConsumerFactory in org.springframework.pulsar.spring.cloud.stream.binder
Constructors in org.springframework.pulsar.spring.cloud.stream.binder with parameters of type PulsarConsumerFactoryModifierConstructorDescriptionPulsarMessageChannelBinder(PulsarTopicProvisioner provisioningProvider, PulsarTemplate<Object> pulsarTemplate, PulsarConsumerFactory<?> pulsarConsumerFactory, PulsarBinderConfigurationProperties binderConfigProps, SchemaResolver schemaResolver, PulsarHeaderMapper headerMapper) -
Uses of PulsarConsumerFactory in org.springframework.pulsar.spring.cloud.stream.binder.config
Methods in org.springframework.pulsar.spring.cloud.stream.binder.config with parameters of type PulsarConsumerFactoryModifier and TypeMethodDescriptionPulsarBinderConfiguration.pulsarMessageChannelBinder(PulsarTopicProvisioner pulsarTopicProvisioner, PulsarTemplate<Object> pulsarTemplate, PulsarConsumerFactory<byte[]> pulsarConsumerFactory, PulsarBinderConfigurationProperties binderConfigProps, PulsarExtendedBindingProperties bindingConfigProps, SchemaResolver schemaResolver, PulsarHeaderMapper headerMapper)