Uses of Interface
org.apache.pulsar.spring.core.ProducerBuilderCustomizer
Packages that use ProducerBuilderCustomizer
Package
Description
Package containing the core components of the framework.
Package containing components to support Pulsar internal logging functionality.
-
Uses of ProducerBuilderCustomizer in org.apache.pulsar.spring.core
Methods in org.apache.pulsar.spring.core with parameters of type ProducerBuilderCustomizerModifier and TypeMethodDescriptionorg.apache.pulsar.client.api.Producer<T> DefaultPulsarProducerFactory.createProducer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable String topic, @Nullable ProducerBuilderCustomizer<T> customizer) org.apache.pulsar.client.api.Producer<T> PulsarProducerFactory.createProducer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable String topic, @Nullable ProducerBuilderCustomizer<T> customizer) Create a producer.PulsarOperations.SendMessageBuilder.withProducerCustomizer(ProducerBuilderCustomizer<T> producerCustomizer) Specifies the customizer to use to further configure the producer builder.PulsarTemplate.SendMessageBuilderImpl.withProducerCustomizer(ProducerBuilderCustomizer<T> producerCustomizer) Method parameters in org.apache.pulsar.spring.core with type arguments of type ProducerBuilderCustomizerModifier and TypeMethodDescriptionorg.apache.pulsar.client.api.Producer<T> DefaultPulsarProducerFactory.createProducer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable String topic, @Nullable Collection<String> encryptionKeys, @Nullable List<ProducerBuilderCustomizer<T>> customizers) org.apache.pulsar.client.api.Producer<T> PulsarProducerFactory.createProducer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable String topic, @Nullable Collection<String> encryptionKeys, @Nullable List<ProducerBuilderCustomizer<T>> customizers) Create a producer.protected org.apache.pulsar.client.api.Producer<T> CachingPulsarProducerFactory.doCreateProducer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable String topic, @Nullable Collection<String> encryptionKeys, @Nullable List<ProducerBuilderCustomizer<T>> customizers) protected org.apache.pulsar.client.api.Producer<T> DefaultPulsarProducerFactory.doCreateProducer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable String topic, @Nullable Collection<String> encryptionKeys, @Nullable List<ProducerBuilderCustomizer<T>> customizers) Create the actual producer.Constructor parameters in org.apache.pulsar.spring.core with type arguments of type ProducerBuilderCustomizerModifierConstructorDescriptionCachingPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, @Nullable String defaultTopic, List<ProducerBuilderCustomizer<T>> defaultConfigCustomizers, TopicResolver topicResolver, Duration cacheExpireAfterAccess, Long cacheMaximumSize, Integer cacheInitialCapacity) Construct a caching producer factory with the specified values for the cache configuration.DefaultPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, @Nullable String defaultTopic, @Nullable List<ProducerBuilderCustomizer<T>> defaultConfigCustomizers) Construct a producer factory that uses a default topic resolver.DefaultPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, @Nullable String defaultTopic, @Nullable List<ProducerBuilderCustomizer<T>> defaultConfigCustomizers, TopicResolver topicResolver) Construct a producer factory that uses the specified parameters. -
Uses of ProducerBuilderCustomizer in org.apache.pulsar.spring.support.internal.logging
Methods in org.apache.pulsar.spring.support.internal.logging with parameters of type ProducerBuilderCustomizerModifier and TypeMethodDescriptionvoidLambdaCustomizerWarnLogger.maybeLog(ProducerBuilderCustomizer<?> producerCustomizer) Log a warning if the given customizer is implemented as a Lambda.