クラス PulsarTemplate.SendMessageBuilderImpl<T>

メソッドの詳細

• withTopic

  public PulsarOperations.SendMessageBuilder<T> withTopic(StringSE topic)

  インターフェースからコピーされた説明: 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() throws org.apache.pulsar.client.api.PulsarClientException

  インターフェースからコピーされた説明: PulsarOperations.SendMessageBuilder

  構成された仕様を使用して、メッセージをブロック方式で送信します。

  次で指定:

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

  戻り値:

  パブリッシュされたメッセージにブローカーによって割り当てられた ID

  例外:

  org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合

• sendAsync

  public CompletableFutureSE<org.apache.pulsar.client.api.MessageId> sendAsync() throws org.apache.pulsar.client.api.PulsarClientException

  インターフェースからコピーされた説明: PulsarOperations.SendMessageBuilder

  構成された仕様を使用して、ノンブロッキング方式でメッセージを送信します。

  次で指定:

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

  戻り値:

  パブリッシュされたメッセージにブローカーによって割り当てられた ID を保持する Future

  例外:

  org.apache.pulsar.client.api.PulsarClientException - エラーが発生した場合