インターフェース RabbitStreamOperations

  • すべてのスーパーインターフェース:
    AutoCloseableSE
    すべての既知の実装クラス:
    RabbitStreamTemplate

    public interface RabbitStreamOperations
    extends AutoCloseableSE
    RabbitMQ Stream プロデューサーを使用してメッセージを送信するためのメソッドを提供します。
    導入:
    2.4
    作成者:
    Gary Russell
    • メソッドの詳細

      • 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)
        Spring AMQP メッセージに変換して送信します。MessagePostProcessor が提供され、null が返された場合、メッセージは送信されず、未来は false で完了します。
        パラメーター:
        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()
        ストリームメッセージコンバーターを返します。
        戻り値:
        コンバーター ;