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

インターフェース PulsarOperations<T>

型パラメーター:
T - メッセージのペイロード型
すべての既知の実装クラス:
PulsarTemplate
public interface PulsarOperations<T>
Pulsar の基本運用契約。
作成者:
Chris Bono, Alexander Preu ß , Jonas Geiregat

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

    ネストされたクラス
    修飾子と型
    インターフェース
    説明
    static interface
    PulsarOperations.SendMessageBuilder<T>
    メッセージの構成と送信に使用できるビルダー。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    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)
    非ブロック的な方法でデフォルトのトピックにメッセージを送信します。

  • メソッドの詳細

    • send

      org.apache.pulsar.client.api.MessageId send(@Nullable T message)
      ブロック方式でデフォルトのトピックにメッセージを送信します。
      パラメーター:
      message - 送信するメッセージ
      戻り値:
      パブリッシュされたメッセージにブローカーによって割り当てられた ID
      例外:
      PulsarException - Pulsar との通信中に PulsarClientException が発生した場合

    • send

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

    • send

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

    • send

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

    • sendAsync

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

    • sendAsync

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

    • sendAsync

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

    • sendAsync

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

    • newMessage

      PulsarOperations.SendMessageBuilder<T> newMessage(@Nullable T message)
      メッセージを構成して送信するための builder を作成します。
      パラメーター:
      message - メッセージのペイロード
      戻り値:
      メッセージを構成して送信するビルダー