クラス DefaultPulsarProducerFactory<T>
java.lang.ObjectSE
org.springframework.pulsar.core.DefaultPulsarProducerFactory<T>
- 型パラメーター:
T
- プロデューサー型。
- 実装されたすべてのインターフェース:
PulsarProducerFactory<T>
- 既知の直属サブクラス
CachingPulsarProducerFactory
PulsarProducerFactory
のデフォルト実装。- 作成者:
- Soby Chacko, Chris Bono, Alexander Preu ß , Christophe Bornet
コンストラクターのサマリー
コンストラクター説明DefaultPulsarProducerFactory
(org.apache.pulsar.client.api.PulsarClient pulsarClient) デフォルトのトピックリゾルバーを使用するプロデューサーファクトリを構築します。DefaultPulsarProducerFactory
(org.apache.pulsar.client.api.PulsarClient pulsarClient, StringSE defaultTopic) デフォルトのトピックリゾルバーを使用するプロデューサーファクトリを構築します。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) 指定されたパラメーターを使用するプロデューサーファクトリを構築します。メソッドのサマリー
修飾子と型メソッド説明org.apache.pulsar.client.api.Producer<T>
createProducer
(org.apache.pulsar.client.api.Schema<T> schema, StringSE topic) プロデューサーを作成します。org.apache.pulsar.client.api.Producer<T>
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>
createProducer
(org.apache.pulsar.client.api.Schema<T> schema, StringSE topic, ProducerBuilderCustomizer<T> customizer) プロデューサーを作成します。protected org.apache.pulsar.client.api.Producer<T>
doCreateProducer
(org.apache.pulsar.client.api.Schema<T> schema, StringSE topic, CollectionSE<StringSE> encryptionKeys, ListSE<ProducerBuilderCustomizer<T>> customizers) 実際のプロデューサーを作成します。作成されたすべてのプロデューサーに使用するデフォルトのトピックを取得します。org.apache.pulsar.client.api.PulsarClient
プロデューサーファクトリがプロデューサーを作成するために使用する Pulsar クライアントを取得します。protected StringSE
resolveTopicName
(StringSE userSpecifiedTopic)
コンストラクターの詳細
DefaultPulsarProducerFactory
public DefaultPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient) デフォルトのトピックリゾルバーを使用するプロデューサーファクトリを構築します。- パラメーター:
pulsarClient
- プロデューサーの作成に使用されたクライアント
DefaultPulsarProducerFactory
public DefaultPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, @Nullable StringSE defaultTopic) デフォルトのトピックリゾルバーを使用するプロデューサーファクトリを構築します。- パラメーター:
pulsarClient
- プロデューサーの作成に使用されたクライアントdefaultTopic
- プロデューサーに使用するデフォルトのトピック
DefaultPulsarProducerFactory
public DefaultPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, @Nullable StringSE defaultTopic, @Nullable ListSE<ProducerBuilderCustomizer<T>> defaultConfigCustomizers) デフォルトのトピックリゾルバーを使用するプロデューサーファクトリを構築します。- パラメーター:
pulsarClient
- プロデューサーの作成に使用されたクライアントdefaultTopic
- プロデューサーに使用するデフォルトのトピックdefaultConfigCustomizers
- 作成されたプロデューサーに適用するカスタマイザーのオプションのリスト
DefaultPulsarProducerFactory
public DefaultPulsarProducerFactory(org.apache.pulsar.client.api.PulsarClient pulsarClient, @Nullable StringSE defaultTopic, @Nullable ListSE<ProducerBuilderCustomizer<T>> defaultConfigCustomizers, TopicResolver topicResolver) 指定されたパラメーターを使用するプロデューサーファクトリを構築します。- パラメーター:
pulsarClient
- プロデューサーの作成に使用されたクライアントdefaultTopic
- プロデューサーに使用するデフォルトのトピックdefaultConfigCustomizers
- 作成されたプロデューサーに適用するカスタマイザーのオプションのリストtopicResolver
- 使用するトピックリゾルバー
メソッドの詳細
createProducer
public org.apache.pulsar.client.api.Producer<T> createProducer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable StringSE topic) インターフェースからコピーされた説明:PulsarProducerFactory
プロデューサーを作成します。- 次で指定:
- インターフェース
PulsarProducerFactory<T>
のcreateProducer
- パラメーター:
schema
- 送信されるメッセージのスキーマtopic
- プロデューサーがメッセージを送信するトピック、またはデフォルトのトピックを使用するnull
- 戻り値:
- プロデューサー
createProducer
public org.apache.pulsar.client.api.Producer<T> createProducer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable StringSE topic, @Nullable ProducerBuilderCustomizer<T> customizer) インターフェースからコピーされた説明:PulsarProducerFactory
プロデューサーを作成します。- 次で指定:
- インターフェース
PulsarProducerFactory<T>
のcreateProducer
- パラメーター:
schema
- 送信されるメッセージのスキーマtopic
- プロデューサーがメッセージを送信するトピック、またはデフォルトのトピックを使用するnull
customizer
- プロデューサービルダーに適用するオプションのカスタマイザー- 戻り値:
- プロデューサー
createProducer
public org.apache.pulsar.client.api.Producer<T> createProducer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable StringSE topic, @Nullable CollectionSE<StringSE> encryptionKeys, @Nullable ListSE<ProducerBuilderCustomizer<T>> customizers) インターフェースからコピーされた説明:PulsarProducerFactory
プロデューサーを作成します。- 次で指定:
- インターフェース
PulsarProducerFactory<T>
のcreateProducer
- パラメーター:
schema
- 送信されるメッセージのスキーマtopic
- プロデューサーがメッセージを送信するトピック、またはデフォルトのトピックを使用するnull
encryptionKeys
- プロデューサーが使用する暗号化キー。デフォルトの暗号化キーを置き換えるか、null
がデフォルトの暗号化キーを使用します。ProducerBuilder
にはProducerBuilder.addEncryptionKey(java.lang.String)
のみがあり、暗号化キーを置き換えるメソッドがないことに注意してください。customizers
- プロデューサービルダーに適用するカスタマイザーのオプションのリスト- 戻り値:
- プロデューサー
getPulsarClient
public org.apache.pulsar.client.api.PulsarClient getPulsarClient()インターフェースからコピーされた説明:PulsarProducerFactory
プロデューサーファクトリがプロデューサーを作成するために使用する Pulsar クライアントを取得します。- 次で指定:
- インターフェース
PulsarProducerFactory<T>
のgetPulsarClient
- 戻り値:
- プロデューサーファクトリがプロデューサーを作成するために使用する Pulsar クライアント
doCreateProducer
protected org.apache.pulsar.client.api.Producer<T> doCreateProducer(org.apache.pulsar.client.api.Schema<T> schema, @Nullable StringSE topic, @Nullable CollectionSE<StringSE> encryptionKeys, @Nullable ListSE<ProducerBuilderCustomizer<T>> customizers) 実際のプロデューサーを作成します。- パラメーター:
schema
- 送信されるメッセージのスキーマtopic
- プロデューサーがメッセージを送信するトピック、またはデフォルトのトピックを使用するnull
encryptionKeys
- プロデューサーが使用する暗号化キー。デフォルトの暗号化キーを置き換えるか、null
がデフォルトの暗号化キーを使用します。ProducerBuilder
にはProducerBuilder.addEncryptionKey(java.lang.String)
のみがあり、暗号化キーを置き換えるメソッドがないことに注意してください。customizers
- プロデューサービルダーに適用するカスタマイザーのオプションのリスト- 戻り値:
- 作られたプロデューサー
- 例外:
org.apache.pulsar.client.api.PulsarClientException
- エラーが発生した場合
resolveTopicName
getDefaultTopic
インターフェースからコピーされた説明:PulsarProducerFactory
作成されたすべてのプロデューサーに使用するデフォルトのトピックを取得します。- 次で指定:
- インターフェース
PulsarProducerFactory<T>
のgetDefaultTopic
- 戻り値:
- 作成されたすべてのプロデューサーに使用するデフォルトのトピック、またはデフォルトが設定されていない場合は null