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