パッケージ org.springframework.pulsar.core

クラス DefaultPulsarProducerFactory<T>

java.lang.ObjectSE
org.springframework.pulsar.core.DefaultPulsarProducerFactory<T>
型パラメーター:
T - プロデューサー型。
実装されたすべてのインターフェース:
PulsarProducerFactory<T>
既知の直属サブクラス
CachingPulsarProducerFactory
public class DefaultPulsarProducerFactory<T> extends ObjectSE implements PulsarProducerFactory<T>
PulsarProducerFactory のデフォルト実装。
作成者:
Soby Chacko, Chris Bono, Alexander Preu ß , Christophe Bornet

  • コンストラクターの詳細

    • 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) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarProducerFactory
      プロデューサーを作成します。
      次で指定:
      インターフェース PulsarProducerFactory<T> の createProducer 
      パラメーター:
      schema - 送信されるメッセージのスキーマ
      topic - プロデューサーがメッセージを送信するトピック、またはデフォルトのトピックを使用する null 
      戻り値:
      プロデューサー
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • 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) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarProducerFactory
      プロデューサーを作成します。
      次で指定:
      インターフェース PulsarProducerFactory<T> の createProducer 
      パラメーター:
      schema - 送信されるメッセージのスキーマ
      topic - プロデューサーがメッセージを送信するトピック、またはデフォルトのトピックを使用する null 
      customizer - プロデューサービルダーに適用するオプションのカスタマイザー
      戻り値:
      プロデューサー
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • 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) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarProducerFactory
      プロデューサーを作成します。
      次で指定:
      インターフェース PulsarProducerFactory<T> の createProducer 
      パラメーター:
      schema - 送信されるメッセージのスキーマ
      topic - プロデューサーがメッセージを送信するトピック、またはデフォルトのトピックを使用する null 
      encryptionKeys - プロデューサーが使用する暗号化キー。デフォルトの暗号化キーを置き換えるか、null がデフォルトの暗号化キーを使用します。ProducerBuilder には ProducerBuilder.addEncryptionKey(java.lang.String) のみがあり、暗号化キーを置き換えるメソッドがないことに注意してください。
      customizers - プロデューサービルダーに適用するカスタマイザーのオプションのリスト
      戻り値:
      プロデューサー
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • 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) throws org.apache.pulsar.client.api.PulsarClientException
      実際のプロデューサーを作成します。
      パラメーター:
      schema - 送信されるメッセージのスキーマ
      topic - プロデューサーがメッセージを送信するトピック、またはデフォルトのトピックを使用する null 
      encryptionKeys - プロデューサーが使用する暗号化キー。デフォルトの暗号化キーを置き換えるか、null がデフォルトの暗号化キーを使用します。ProducerBuilder には ProducerBuilder.addEncryptionKey(java.lang.String) のみがあり、暗号化キーを置き換えるメソッドがないことに注意してください。
      customizers - プロデューサービルダーに適用するカスタマイザーのオプションのリスト
      戻り値:
      作られたプロデューサー
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • resolveTopicName

      protected StringSE resolveTopicName(StringSE userSpecifiedTopic)

    • getDefaultTopic

      public StringSE getDefaultTopic()
      インターフェースからコピーされた説明: PulsarProducerFactory
      作成されたすべてのプロデューサーに使用するデフォルトのトピックを取得します。
      次で指定:
      インターフェース PulsarProducerFactory<T> の getDefaultTopic 
      戻り値:
      作成されたすべてのプロデューサーに使用するデフォルトのトピック、またはデフォルトが設定されていない場合は null