インターフェース RabbitStreamOperations
- すべてのスーパーインターフェース:
AutoCloseableSE
- すべての既知の実装クラス:
RabbitStreamTemplate
public interface RabbitStreamOperations extends AutoCloseableSE
RabbitMQ Stream プロデューサーを使用してメッセージを送信するためのメソッドを提供します。- 導入:
- 2.4
- 作成者:
- Gary Russell
方法の概要
すべてのメソッド インスタンスメソッド 抽象メソッド デフォルトメソッド 修飾子と型 メソッド 説明 default voidclose()ListenableFuture<BooleanSE>convertAndSend(ObjectSE message)Spring AMQP メッセージに変換して送信します。ListenableFuture<BooleanSE>convertAndSend(ObjectSE message, MessagePostProcessor mpp)Spring AMQP メッセージに変換して送信します。com.rabbitmq.stream.MessageBuildermessageBuilder()プロデューサーのMessageBuilderを返して、ネイティブストリームメッセージを作成します。MessageConvertermessageConverter()メッセージコンバーターを返します。ListenableFuture<BooleanSE>send(com.rabbitmq.stream.Message message)ネイティブストリームメッセージを送信します。ListenableFuture<BooleanSE>send(Message message)Spring AMQP メッセージを送信します。StreamMessageConverterstreamMessageConverter()ストリームメッセージコンバーターを返します。
メソッドの詳細
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