通常は単純なフローで Spring Cloud DataFlow の評価に成功しています。プロセッサ | シンク。
デプロイには、データ フロー ラベルを使用して実行できる、このパイプラインにフィードする複数のソースがあります。すべて順調です。
各ソースは異なる rabbitmq インスタンスであり、プロセッサはメッセージの送信元を知る必要があるため (詳細情報を取得するにはソース システムにコールバックする必要があるため)、私が考えた戦略は、各メッセージをヘッダーで強化することでした。ソースシステムに関する詳細は、プロセッサに透過的に渡されます。
今、私はSpring、Spring Boot、およびSpring Integrationに精通していますが、データフローソースコンポーネントの各メッセージを充実させる方法を見つけることができません.
ソース コンポーネントは org.springframework.cloud.stream.app.rabbit.source.RabbitSourceConfiguration にバインドされます。ソースは、デフォルトの Source.OUTPUT チャネルを使用します。ソース内の各メッセージを取得して充実させるにはどうすればよいですか?
私のプロセッサ コンポーネントは、Spring Integration DSL を使用して必要なことの一部を実行しますが、このプロセッサ コンポーネントには定義上、INPUT チャネルと OUTPUT チャネルの両方があります。RabbitSourceConfiguration ソースではそうではありません。
それで、これはできますか？