Uses of Interface
org.springframework.pulsar.core.ConsumerBuilderCustomizer
Package
Description
Package containing Spring configuration classes for the framework.
Package containing the core components of the framework.
Package containing listener components for receiving Pulsar messages.
-
Uses of ConsumerBuilderCustomizer in org.springframework.pulsar.config
Modifier and TypeMethodDescriptionvoid
MethodPulsarListenerEndpoint.setConsumerBuilderCustomizer
(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer) -
Uses of ConsumerBuilderCustomizer in org.springframework.pulsar.core
Modifier and TypeMethodDescriptionorg.apache.pulsar.client.api.Consumer<T>
DefaultPulsarConsumerFactory.createConsumer
(org.apache.pulsar.client.api.Schema<T> schema, Collection<String> topics, String subscriptionName, ConsumerBuilderCustomizer<T> customizer) org.apache.pulsar.client.api.Consumer<T>
PulsarConsumerFactory.createConsumer
(org.apache.pulsar.client.api.Schema<T> schema, Collection<String> topics, String subscriptionName, ConsumerBuilderCustomizer<T> customizer) Create a consumer.Modifier and TypeMethodDescriptionorg.apache.pulsar.client.api.Consumer<T>
DefaultPulsarConsumerFactory.createConsumer
(org.apache.pulsar.client.api.Schema<T> schema, Collection<String> topics, String subscriptionName, Map<String, String> metadataProperties, List<ConsumerBuilderCustomizer<T>> customizers) org.apache.pulsar.client.api.Consumer<T>
PulsarConsumerFactory.createConsumer
(org.apache.pulsar.client.api.Schema<T> schema, Collection<String> topics, String subscriptionName, Map<String, String> metadataProperties, List<ConsumerBuilderCustomizer<T>> customizers) Create a consumer.ModifierConstructorDescriptionDefaultPulsarConsumerFactory
(org.apache.pulsar.client.api.PulsarClient pulsarClient, List<ConsumerBuilderCustomizer<T>> defaultConfigCustomizers) Construct a consumer factory instance. -
Uses of ConsumerBuilderCustomizer in org.springframework.pulsar.listener
Modifier and TypeFieldDescriptionprotected ConsumerBuilderCustomizer<T>
AbstractPulsarMessageListenerContainer.consumerBuilderCustomizer
Modifier and TypeMethodDescriptionAbstractPulsarMessageListenerContainer.getConsumerBuilderCustomizer()
Modifier and TypeMethodDescriptionvoid
AbstractPulsarMessageListenerContainer.setConsumerCustomizer
(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer) void
PulsarMessageListenerContainer.setConsumerCustomizer
(ConsumerBuilderCustomizer<?> consumerBuilderCustomizer) Set a consumer customizer on this container.