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

クラス DefaultPulsarClientFactory

java.lang.ObjectSE
org.springframework.pulsar.core.DefaultPulsarClientFactory
実装されたすべてのインターフェース:
Aware、EnvironmentAware、PulsarClientFactory
public class DefaultPulsarClientFactory extends ObjectSE implements PulsarClientFactory, EnvironmentAware
PulsarClientFactory のデフォルト実装。
作成者:
Soby Chacko, Chris Bono

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

    • DefaultPulsarClientFactory

      public DefaultPulsarClientFactory(StringSE serviceUrl)
      指定されたサービス URL 以外は変更せずに、デフォルトの Pulsar クライアントビルダーを使用してクライアントを作成するファクトリを構築します。
      パラメーター:
      serviceUrl - サービスの URL

    • DefaultPulsarClientFactory

      public DefaultPulsarClientFactory(PulsarClientBuilderCustomizer customizer)
      カスタマイズされた Pulsar クライアントビルダーを使用してクライアントを作成するファクトリを構築します。
      パラメーター:
      customizer - ビルダーに適用するカスタマイザー

  • メソッドの詳細

    • createClient

      public org.apache.pulsar.client.api.PulsarClient createClient() throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarClientFactory
      クライアントを作成します。
      次で指定:
      インターフェース PulsarClientFactory の createClient 
      戻り値:
      作成されたクライアントインスタンス
      例外:
      org.apache.pulsar.client.api.PulsarClientException - クライアントの作成中にエラーが発生した場合

    • setEnvironment

      public void setEnvironment(Environment environment)
      次で指定:
      インターフェース EnvironmentAware の setEnvironment