インターフェース PulsarOperations.SendMessageBuilder<T>
- 型パラメーター:
T
- メッセージのペイロード型
- すべての既知の実装クラス:
PulsarTemplate.SendMessageBuilderImpl
- 含まれているインターフェース:
- PulsarOperations<T>
public static interface PulsarOperations.SendMessageBuilder<T>
メッセージの設定と送信に使用できるビルダー。
PulsarOperations
が提供する基本的な send/sendAsync メソッドよりも多くのオプションを提供します。メソッドのサマリー
修飾子と型メソッド説明org.apache.pulsar.client.api.MessageId
send()
構成された仕様を使用して、メッセージをブロック方式で送信します。CompletableFutureSE<org.apache.pulsar.client.api.MessageId>
構成された仕様を使用して、ノンブロッキング方式でメッセージを送信します。withEncryptionKeys
(CollectionSE<StringSE> encryptionKeys) 使用する暗号化キーを指定します。withMessageCustomizer
(TypedMessageBuilderCustomizer<T> messageCustomizer) メッセージをさらに構成するために使用するメッセージカスタマイザーを指定します。withProducerCustomizer
(ProducerBuilderCustomizer<T> producerCustomizer) プロデューサービルダーをさらに構成するために使用するカスタマイザーを指定します。withSchema
(org.apache.pulsar.client.api.Schema<T> schema) メッセージの送信時に使用するスキーマを指定します。メッセージの送信先のトピックを指定します。
メソッドの詳細
withTopic
メッセージの送信先のトピックを指定します。- パラメーター:
topic
- 宛先のトピック- 戻り値:
- 宛先トピックが指定された現在のビルダー
withSchema
メッセージの送信時に使用するスキーマを指定します。- パラメーター:
schema
- 使用するスキーマ- 戻り値:
- スキーマが指定された現在のビルダー
withEncryptionKeys
使用する暗号化キーを指定します。- パラメーター:
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()構成された仕様を使用して、メッセージをブロック方式で送信します。- 戻り値:
- パブリッシュされたメッセージにブローカーによって割り当てられた ID
- 例外:
PulsarException
- エラーが発生した場合
sendAsync
CompletableFutureSE<org.apache.pulsar.client.api.MessageId> sendAsync()構成された仕様を使用して、ノンブロッキング方式でメッセージを送信します。- 戻り値:
- パブリッシュされたメッセージにブローカーによって割り当てられた ID を保持する Future
- 例外:
PulsarException
- エラーが発生した場合