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

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

型パラメーター:
T - メッセージのペイロード型
すべての既知の実装クラス:
PulsarTemplate.SendMessageBuilderImpl
含まれているインターフェース:
PulsarOperations<T>
public static interface PulsarOperations.SendMessageBuilder<T>
メッセージの構成と送信に使用できるビルダー。PulsarOperations が提供する基本的な send/sendAsync メソッドよりも多くのオプションを提供します。

  • メソッドの詳細

    • withTopic

      PulsarOperations.SendMessageBuilder<T> withTopic(StringSE topic)
      メッセージの送信先のトピックを指定します。
      パラメーター:
      topic - 宛先のトピック
      戻り値:
      宛先トピックが指定された現在のビルダー

    • withSchema

      PulsarOperations.SendMessageBuilder<T> withSchema(org.apache.pulsar.client.api.Schema<T> schema)
      メッセージの送信時に使用するスキーマを指定します。
      パラメーター:
      schema - 使用するスキーマ
      戻り値:
      スキーマが指定された現在のビルダー

    • withEncryptionKeys

      PulsarOperations.SendMessageBuilder<T> withEncryptionKeys(CollectionSE<StringSE> encryptionKeys)
      使用する暗号化キーを指定します。
      パラメーター:
      encryptionKeys - 暗号化キー
      戻り値:
      暗号化キーが指定された現在のビルダー

    • withMessageCustomizer

      PulsarOperations.SendMessageBuilder<T> withMessageCustomizer(TypedMessageBuilderCustomizer<T> messageCustomizer)
      メッセージをさらに構成するために使用するメッセージカスタマイザーを指定します。
      パラメーター:
      messageCustomizer - メッセージカスタマイザー
      戻り値:
      メッセージカスタマイザーが指定された現在のビルダー

    • withProducerCustomizer

      PulsarOperations.SendMessageBuilder<T> withProducerCustomizer(ProducerBuilderCustomizer<T> producerCustomizer)
      プロデューサービルダーをさらに構成するために使用するカスタマイザーを指定します。
      パラメーター:
      producerCustomizer - プロデューサービルダーカスタマイザー
      戻り値:
      プロデューサービルダーカスタマイザーが指定された現在のビルダー

    • send

      org.apache.pulsar.client.api.MessageId send() throws org.apache.pulsar.client.api.PulsarClientException
      構成された仕様を使用して、メッセージをブロック方式で送信します。
      戻り値:
      パブリッシュされたメッセージにブローカーによって割り当てられた ID
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

    • sendAsync

      CompletableFutureSE<org.apache.pulsar.client.api.MessageId> sendAsync() throws org.apache.pulsar.client.api.PulsarClientException
      構成された仕様を使用して、ノンブロッキング方式でメッセージを送信します。
      戻り値:
      パブリッシュされたメッセージにブローカーによって割り当てられた ID を保持する Future
      例外:
      org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合