インターフェース RabbitStreamOperations
- すべてのスーパーインターフェース:
AutoCloseableSE
- すべての既知の実装クラス:
RabbitStreamTemplate
RabbitMQ Stream プロデューサーを使用してメッセージを送信するためのメソッドを提供します。
- 導入:
- 2.4
- 作成者:
- Gary Russell
メソッドのサマリー
修飾子と型メソッド説明default void
close()
convertAndSend
(ObjectSE message) Spring AMQP メッセージに変換して送信します。convertAndSend
(ObjectSE message, MessagePostProcessor mpp) Spring AMQP メッセージに変換して送信します。com.rabbitmq.stream.MessageBuilder
プロデューサーのMessageBuilder
を返して、ネイティブストリームメッセージを作成します。メッセージコンバーターを返します。send
(com.rabbitmq.stream.Message message) ネイティブストリームメッセージを送信します。Spring AMQP メッセージを送信します。ストリームメッセージコンバーターを返します。
メソッドの詳細
send
Spring AMQP メッセージを送信します。- パラメーター:
message
- メッセージ。- 戻り値:
- 成功 / 失敗を示す未来。
convertAndSend
Spring AMQP メッセージに変換して送信します。- パラメーター:
message
- ペイロード。- 戻り値:
- 成功 / 失敗を示す未来。
convertAndSend
- パラメーター:
message
- ペイロード。mpp
- メッセージポストプロセッサー。- 戻り値:
- 成功 / 失敗を示す未来。
send
ネイティブストリームメッセージを送信します。- パラメーター:
message
- メッセージ。- 戻り値:
- 成功 / 失敗を示す未来。
- 関連事項:
messageBuilder
com.rabbitmq.stream.MessageBuilder messageBuilder()プロデューサーのMessageBuilder
を返して、ネイティブストリームメッセージを作成します。- 戻り値:
- ビルダー。
- 関連事項:
messageConverter
MessageConverter messageConverter()メッセージコンバーターを返します。- 戻り値:
- コンバーター。
streamMessageConverter
StreamMessageConverter streamMessageConverter()ストリームメッセージコンバーターを返します。- 戻り値:
- コンバーター ;
close
- 次で指定:
- インターフェース
AutoCloseableSE
のclose
- 例外:
AmqpException