クラス PulsarTemplate.SendMessageBuilderImpl<T>
java.lang.ObjectSE
org.springframework.pulsar.core.PulsarTemplate.SendMessageBuilderImpl<T>
- 実装されたすべてのインターフェース:
PulsarOperations.SendMessageBuilder<T>
- 含まれているクラス:
- PulsarTemplate<T>
public static class PulsarTemplate.SendMessageBuilderImpl<T>
extends ObjectSE
implements PulsarOperations.SendMessageBuilder<T>
メソッドのサマリー
修飾子と型メソッド説明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
インターフェースからコピーされた説明:PulsarOperations.SendMessageBuilder
メッセージの送信先のトピックを指定します。- 次で指定:
- インターフェース
PulsarOperations.SendMessageBuilder<T>
のwithTopic
- パラメーター:
topic
- 宛先のトピック- 戻り値:
- 宛先トピックが指定された現在のビルダー
withSchema
public PulsarOperations.SendMessageBuilder<T> withSchema(org.apache.pulsar.client.api.Schema<T> schema) インターフェースからコピーされた説明:PulsarOperations.SendMessageBuilder
メッセージの送信時に使用するスキーマを指定します。- 次で指定:
- インターフェース
PulsarOperations.SendMessageBuilder<T>
のwithSchema
- パラメーター:
schema
- 使用するスキーマ- 戻り値:
- スキーマが指定された現在のビルダー
withEncryptionKeys
public PulsarOperations.SendMessageBuilder<T> withEncryptionKeys(CollectionSE<StringSE> encryptionKeys) インターフェースからコピーされた説明:PulsarOperations.SendMessageBuilder
使用する暗号化キーを指定します。- 次で指定:
- インターフェース
PulsarOperations.SendMessageBuilder<T>
のwithEncryptionKeys
- パラメーター:
encryptionKeys
- 暗号化キー- 戻り値:
- 暗号化キーが指定された現在のビルダー
withMessageCustomizer
public PulsarOperations.SendMessageBuilder<T> withMessageCustomizer(TypedMessageBuilderCustomizer<T> messageCustomizer) インターフェースからコピーされた説明:PulsarOperations.SendMessageBuilder
メッセージをさらに構成するために使用するメッセージカスタマイザーを指定します。- 次で指定:
- インターフェース
PulsarOperations.SendMessageBuilder<T>
のwithMessageCustomizer
- パラメーター:
messageCustomizer
- メッセージカスタマイザー- 戻り値:
- メッセージカスタマイザーが指定された現在のビルダー
withProducerCustomizer
public PulsarOperations.SendMessageBuilder<T> withProducerCustomizer(ProducerBuilderCustomizer<T> producerCustomizer) インターフェースからコピーされた説明:PulsarOperations.SendMessageBuilder
プロデューサービルダーをさらに構成するために使用するカスタマイザーを指定します。- 次で指定:
- インターフェース
PulsarOperations.SendMessageBuilder<T>
のwithProducerCustomizer
- パラメーター:
producerCustomizer
- プロデューサービルダーカスタマイザー- 戻り値:
- プロデューサービルダーカスタマイザーが指定された現在のビルダー
send
public org.apache.pulsar.client.api.MessageId send()インターフェースからコピーされた説明:PulsarOperations.SendMessageBuilder
構成された仕様を使用して、メッセージをブロック方式で送信します。- 次で指定:
- インターフェース
PulsarOperations.SendMessageBuilder<T>
のsend
- 戻り値:
- パブリッシュされたメッセージにブローカーによって割り当てられた ID
sendAsync
インターフェースからコピーされた説明:PulsarOperations.SendMessageBuilder
構成された仕様を使用して、ノンブロッキング方式でメッセージを送信します。- 次で指定:
- インターフェース
PulsarOperations.SendMessageBuilder<T>
のsendAsync
- 戻り値:
- パブリッシュされたメッセージにブローカーによって割り当てられた ID を保持する Future