インターフェース RabbitStreamOperations

すべてのスーパーインターフェース:
AutoCloseableSE
すべての既知の実装クラス:
RabbitStreamTemplate
public interface RabbitStreamOperations extends AutoCloseableSE
RabbitMQ Stream プロデューサーを使用してメッセージを送信するためのメソッドを提供します。
導入:
2.4
作成者:
Gary Russell

  • メソッドの詳細

    • 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

      com.rabbitmq.stream.MessageBuilder messageBuilder()
      プロデューサーの MessageBuilder を返して、ネイティブストリームメッセージを作成します。
      戻り値:
      ビルダー。
      関連事項:

    • messageConverter

      MessageConverter messageConverter()
      メッセージコンバーターを返します。
      戻り値:
      コンバーター。

    • streamMessageConverter

      StreamMessageConverter streamMessageConverter()
      ストリームメッセージコンバーターを返します。
      戻り値:
      コンバーター ;

    • close

      default void close() throws AmqpException
      次で指定:
      インターフェース AutoCloseableSE の close 
      例外:
      AmqpException