現在、既存の Spring Cloud Stream アプリを移植して、代わりに Spring Cloud Function を使用しようとしています。アプリケーションを実行するとき、バインディングを使用して入力キュー (Kafka または IBMMQ) からマップします。キューで送信されたメッセージは、カスタム MessageConverter を介して渡され、カスタム ルーティング関数に渡されます。
Spring Cloud Stream では、バインディングにより、たとえば (input() の呼び出しを介して) テスト キューへの直接アクセスが許可され、そのキューでメッセージを送信するだけで、プロセスのローリングを開始できました。
私が見つけようとしているのは、Spring Cloud Function がバインドされているキューにメッセージを送信するための同様のメカニズムです。問題は、それを行う方法を理解できないように見えることです。
HTTP経由でroutingFunctionにアクセスする方法を見てきましたが、残念ながら、これはMessageConverterをバイパスするため、エンドツーエンドのテストを実際に行うことはまだできません.
これを Cloud Function で動作させる方法についてのアイデアや指針はありますか?