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

クラス PulsarTemplate<T>

java.lang.ObjectSE
org.springframework.pulsar.core.PulsarTemplate<T>
型パラメーター:
T - メッセージのペイロード型
実装されたすべてのインターフェース:
Aware、BeanNameAware、SmartInitializingSingleton、ApplicationContextAware、PulsarOperations<T>
public class PulsarTemplate<T> extends ObjectSE implements PulsarOperations<T>, ApplicationContextAware, BeanNameAware, SmartInitializingSingleton
高レベルの Pulsar 操作を実行するためのテンプレート。
作成者:
Soby Chacko, Chris Bono, Alexander Preu ß , Christophe Bornet

  • ネストされたクラスのサマリー

    ネストされたクラス
    修飾子と型
    クラス
    説明
    static class
    PulsarTemplate.SendMessageBuilderImpl<T>

    インターフェース org.springframework.pulsar.core.PulsarOperations から継承されたネストクラス / インターフェース

    PulsarOperations.SendMessageBuilder<T>

  • コンストラクターのサマリー

    コンストラクター
    コンストラクター
    説明
    PulsarTemplate(PulsarProducerFactory<T> producerFactory)
    インターセプターなしで、デフォルトのスキーマリゾルバーを使用するテンプレートインスタンスを構築します。
    PulsarTemplate(PulsarProducerFactory<T> producerFactory, ListSE<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptors)
    デフォルトのスキーマリゾルバーとデフォルトのトピックリゾルバーを使用し、観察記録を有効にするインターセプターを含むテンプレートインスタンスを構築します。
    PulsarTemplate(PulsarProducerFactory<T> producerFactory, ListSE<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptors, SchemaResolver schemaResolver, TopicResolver topicResolver, boolean observationEnabled)
    オプションの監視構成を使用してテンプレートインスタンスを構築します。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    void
    afterSingletonsInstantiated()
    観察が有効な場合は、観察レジストリと規則の取得を試みます。
    PulsarOperations.SendMessageBuilder<T>
    newMessage(T message)
    メッセージを構成して送信するための builder を作成します。
    org.apache.pulsar.client.api.MessageId
    send(StringSE topic, T message)
    指定されたトピックにブロック方式でメッセージを送信します。
    org.apache.pulsar.client.api.MessageId
    send(StringSE topic, T message, org.apache.pulsar.client.api.Schema<T> schema)
    指定されたトピックにブロック方式でメッセージを送信します。
    org.apache.pulsar.client.api.MessageId
    send(T message)
    ブロック方式でデフォルトのトピックにメッセージを送信します。
    org.apache.pulsar.client.api.MessageId
    send(T message, org.apache.pulsar.client.api.Schema<T> schema)
    ブロック方式でデフォルトのトピックにメッセージを送信します。
    CompletableFutureSE<org.apache.pulsar.client.api.MessageId>
    sendAsync(StringSE topic, T message)
    指定されたトピックに非ブロック的な方法でメッセージを送信します。
    CompletableFutureSE<org.apache.pulsar.client.api.MessageId>
    sendAsync(StringSE topic, T message, org.apache.pulsar.client.api.Schema<T> schema)
    指定されたトピックに非ブロック的な方法でメッセージを送信します。
    CompletableFutureSE<org.apache.pulsar.client.api.MessageId>
    sendAsync(T message)
    非ブロック的な方法でデフォルトのトピックにメッセージを送信します。
    CompletableFutureSE<org.apache.pulsar.client.api.MessageId>
    sendAsync(T message, org.apache.pulsar.client.api.Schema<T> schema)
    非ブロック的な方法でデフォルトのトピックにメッセージを送信します。
    void
    setApplicationContext(ApplicationContext applicationContext)
    void
    setBeanName(StringSE beanName)

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

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

    • PulsarTemplate

      public PulsarTemplate(PulsarProducerFactory<T> producerFactory)
      インターセプターなしで、デフォルトのスキーマリゾルバーを使用するテンプレートインスタンスを構築します。
      パラメーター:
      producerFactory - バックの Pulsar プロデューサーを作成するために使用されるファクトリ。

    • PulsarTemplate

      public PulsarTemplate(PulsarProducerFactory<T> producerFactory, ListSE<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptors)
      デフォルトのスキーマリゾルバーとデフォルトのトピックリゾルバーを使用し、観察記録を有効にするインターセプターを含むテンプレートインスタンスを構築します。
      パラメーター:
      producerFactory - バックの Pulsar プロデューサーを作成するために使用されるファクトリ。
      interceptors - プロデューサーに追加するインターセプター。

    • PulsarTemplate

      public PulsarTemplate(PulsarProducerFactory<T> producerFactory, ListSE<org.apache.pulsar.client.api.interceptor.ProducerInterceptor> interceptors, SchemaResolver schemaResolver, TopicResolver topicResolver, boolean observationEnabled)
      オプションの監視構成を使用してテンプレートインスタンスを構築します。
      パラメーター:
      producerFactory - バッキング Pulsar プロデューサーの作成に使用されるファクトリ
      interceptors - プロデューサーに追加するインターセプタのリスト
      schemaResolver - 使用するスキーマリゾルバー
      topicResolver - 使用するトピックリゾルバー
      observationEnabled - 観察を記録するかどうか

  • メソッドの詳細

    • setApplicationContext

      public void setApplicationContext(ApplicationContext applicationContext)
      次で指定:
      インターフェース ApplicationContextAware の setApplicationContext 

    • afterSingletonsInstantiated

      public void afterSingletonsInstantiated()
      観察が有効な場合は、観察レジストリと規則の取得を試みます。
      次で指定:
      インターフェース SmartInitializingSingleton の afterSingletonsInstantiated 

    • send

      public org.apache.pulsar.client.api.MessageId send(@Nullable T message) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarOperations
      ブロック方式でデフォルトのトピックにメッセージを送信します。
      次で指定:
      インターフェース PulsarOperations<T> の send 
      パラメーター:
      message - 送信するメッセージ
      戻り値:
      パブリッシュされたメッセージにブローカーによって割り当てられた ID
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • send

      public org.apache.pulsar.client.api.MessageId send(@Nullable T message, @Nullable org.apache.pulsar.client.api.Schema<T> schema) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarOperations
      ブロック方式でデフォルトのトピックにメッセージを送信します。
      次で指定:
      インターフェース PulsarOperations<T> の send 
      パラメーター:
      message - 送信するメッセージ
      schema - 使用するスキーマ、またはデフォルトのスキーマ解決を使用して送信する null 
      戻り値:
      パブリッシュされたメッセージにブローカーによって割り当てられた ID
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • send

      public org.apache.pulsar.client.api.MessageId send(@Nullable StringSE topic, @Nullable T message) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarOperations
      指定されたトピックにブロック方式でメッセージを送信します。
      次で指定:
      インターフェース PulsarOperations<T> の send 
      パラメーター:
      topic - メッセージの送信先のトピック、またはデフォルトのトピックに送信する null 
      message - 送信するメッセージ
      戻り値:
      パブリッシュされたメッセージにブローカーによって割り当てられた ID
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • send

      public org.apache.pulsar.client.api.MessageId send(@Nullable StringSE topic, @Nullable T message, @Nullable org.apache.pulsar.client.api.Schema<T> schema) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarOperations
      指定されたトピックにブロック方式でメッセージを送信します。
      次で指定:
      インターフェース PulsarOperations<T> の send 
      パラメーター:
      topic - メッセージの送信先のトピック、またはデフォルトのトピックに送信する null 
      message - 送信するメッセージ
      schema - 使用するスキーマ、またはデフォルトのスキーマ解決を使用して送信する null 
      戻り値:
      パブリッシュされたメッセージにブローカーによって割り当てられた ID
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • sendAsync

      public CompletableFutureSE<org.apache.pulsar.client.api.MessageId> sendAsync(@Nullable T message) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarOperations
      非ブロック的な方法でデフォルトのトピックにメッセージを送信します。
      次で指定:
      インターフェース PulsarOperations<T> の sendAsync 
      パラメーター:
      message - 送信するメッセージ
      戻り値:
      パブリッシュされたメッセージにブローカーによって割り当てられた ID を保持する Future
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • sendAsync

      public CompletableFutureSE<org.apache.pulsar.client.api.MessageId> sendAsync(@Nullable T message, @Nullable org.apache.pulsar.client.api.Schema<T> schema) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarOperations
      非ブロック的な方法でデフォルトのトピックにメッセージを送信します。
      次で指定:
      インターフェース PulsarOperations<T> の sendAsync 
      パラメーター:
      message - 送信するメッセージ
      schema - 使用するスキーマ、またはデフォルトのスキーマ解決を使用して送信する null 
      戻り値:
      パブリッシュされたメッセージにブローカーによって割り当てられた ID を保持する Future
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • sendAsync

      public CompletableFutureSE<org.apache.pulsar.client.api.MessageId> sendAsync(@Nullable StringSE topic, @Nullable T message) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarOperations
      指定されたトピックに非ブロック的な方法でメッセージを送信します。
      次で指定:
      インターフェース PulsarOperations<T> の sendAsync 
      パラメーター:
      topic - メッセージの送信先のトピック、またはデフォルトのトピックに送信する null 
      message - 送信するメッセージ
      戻り値:
      パブリッシュされたメッセージにブローカーによって割り当てられた ID を保持する Future
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • sendAsync

      public CompletableFutureSE<org.apache.pulsar.client.api.MessageId> sendAsync(@Nullable StringSE topic, @Nullable T message, @Nullable org.apache.pulsar.client.api.Schema<T> schema) throws org.apache.pulsar.client.api.PulsarClientException
      インターフェースからコピーされた説明: PulsarOperations
      指定されたトピックに非ブロック的な方法でメッセージを送信します。
      次で指定:
      インターフェース PulsarOperations<T> の sendAsync 
      パラメーター:
      topic - メッセージの送信先のトピック、またはデフォルトのトピックに送信する null 
      message - 送信するメッセージ
      schema - 使用するスキーマ、またはデフォルトのスキーマ解決を使用して送信する null 
      戻り値:
      パブリッシュされたメッセージにブローカーによって割り当てられた ID を保持する Future
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • newMessage

      public PulsarOperations.SendMessageBuilder<T> newMessage(@Nullable T message)
      インターフェースからコピーされた説明: PulsarOperations
      メッセージを構成して送信するための builder を作成します。
      次で指定:
      インターフェース PulsarOperations<T> の newMessage 
      パラメーター:
      message - メッセージのペイロード
      戻り値:
      メッセージを構成して送信するビルダー

    • setBeanName

      public void setBeanName(StringSE beanName)
      次で指定:
      インターフェース BeanNameAware の setBeanName