インターフェース RabbitStreamOperations

メソッドの詳細

• send

  CompletableFutureSE<BooleanSE> send(Message message)

  Spring AMQP メッセージを送信します。

  パラメーター:

  message - メッセージ。

  戻り値:

  成功 / 失敗を示す未来。

• convertAndSend

  CompletableFutureSE<BooleanSE> convertAndSend(ObjectSE message)

  Spring AMQP メッセージに変換して送信します。

  パラメーター:

  message - ペイロード。

  戻り値:

  成功 / 失敗を示す未来。

• convertAndSend

  CompletableFutureSE<BooleanSE> convertAndSend(ObjectSE message, @Nullable MessagePostProcessor mpp)

  Spring AMQP メッセージに変換して送信します。MessagePostProcessor が提供され、null が返された場合、メッセージは送信されず、未来は false で完了します。

  パラメーター:

  message - ペイロード。

  mpp - メッセージポストプロセッサー。

  戻り値:

  成功 / 失敗を示す未来。

• send

  CompletableFutureSE<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