インターフェースの使用
org.springframework.pulsar.core.ProducerBuilderCustomizer
org.springframework.pulsar.core 内の ProducerBuilderCustomizer 使用
修飾子と型メソッド説明org.apache.pulsar.client.api.Producer<T>
DefaultPulsarProducerFactory.createProducer
(org.apache.pulsar.client.api.Schema<T> schema, StringSE topic, ProducerBuilderCustomizer<T> customizer) org.apache.pulsar.client.api.Producer<T>
PulsarProducerFactory.createProducer
(org.apache.pulsar.client.api.Schema<T> schema, StringSE topic, ProducerBuilderCustomizer<T> customizer) プロデューサーを作成します。PulsarOperations.SendMessageBuilder.withProducerCustomizer
(ProducerBuilderCustomizer<T> producerCustomizer) プロデューサービルダーをさらに構成するために使用するカスタマイザーを指定します。PulsarTemplate.SendMessageBuilderImpl.withProducerCustomizer
(ProducerBuilderCustomizer<T> producerCustomizer) 修飾子と型メソッド説明org.apache.pulsar.client.api.Producer<T>
DefaultPulsarProducerFactory.createProducer
(org.apache.pulsar.client.api.Schema<T> schema, StringSE topic, CollectionSE<StringSE> encryptionKeys, ListSE<ProducerBuilderCustomizer<T>> customizers) org.apache.pulsar.client.api.Producer<T>
PulsarProducerFactory.createProducer
(org.apache.pulsar.client.api.Schema<T> schema, StringSE topic, CollectionSE<StringSE> encryptionKeys, ListSE<ProducerBuilderCustomizer<T>> customizers) プロデューサーを作成します。protected org.apache.pulsar.client.api.Producer<T>
CachingPulsarProducerFactory.doCreateProducer
(org.apache.pulsar.client.api.Schema<T> schema, StringSE topic, CollectionSE<StringSE> encryptionKeys, ListSE<ProducerBuilderCustomizer<T>> customizers) protected org.apache.pulsar.client.api.Producer<T>
DefaultPulsarProducerFactory.doCreateProducer
(org.apache.pulsar.client.api.Schema<T> schema, StringSE topic, CollectionSE<StringSE> encryptionKeys, ListSE<ProducerBuilderCustomizer<T>> customizers) 実際のプロデューサーを作成します。修飾子コンストラクター説明CachingPulsarProducerFactory
(org.apache.pulsar.client.api.PulsarClient pulsarClient, StringSE defaultTopic, ListSE<ProducerBuilderCustomizer<T>> defaultConfigCustomizers, TopicResolver topicResolver, DurationSE cacheExpireAfterAccess, LongSE cacheMaximumSize, IntegerSE cacheInitialCapacity) キャッシュ構成に指定された値を使用してキャッシュプロデューサーファクトリを構築します。DefaultPulsarProducerFactory
(org.apache.pulsar.client.api.PulsarClient pulsarClient, StringSE defaultTopic, ListSE<ProducerBuilderCustomizer<T>> defaultConfigCustomizers) デフォルトのトピックリゾルバーを使用するプロデューサーファクトリを構築します。DefaultPulsarProducerFactory
(org.apache.pulsar.client.api.PulsarClient pulsarClient, StringSE defaultTopic, ListSE<ProducerBuilderCustomizer<T>> defaultConfigCustomizers, TopicResolver topicResolver) 指定されたパラメーターを使用するプロデューサーファクトリを構築します。