問題タブ [spring-integration-dsl]

私はSpring Integrationにかなり慣れていないので、簡単なユースケースをセットアップしようとしています:

リモート REST エンドポイントをポーリングし、返されたペイロードを複数の行に分割して、Kafka アウトバウンド アダプターに送信します。私は、ファイル アダプタを使用する同様のことを成功させましたが、HTTP アダプタに行き詰まっています。ポーラーを HTTP 受信アダプターに関連付ける方法がわかりません。

これまでのところ、私のアプローチは単純なフローを作成することでした。

はinboundChannelAdapterを受け入れないようですPoller。ファイルを使用した前回の試みFileReadingMessageSourceで、フローが次のようになるように を作成しました。

しかし、HTTP メッセージ ソースに相当するものが見つかりません。

私の意図は、さまざまなソース/ディレクトリから (最初は、後でおそらく ftp から) IntegrationFlow Bean インスタンスを作成することです。したがって、application.propertiesこのようなものを定義したいのですが、受信ディレクトリの数は異なる場合があります。

また、ソースのオリジンを (ヘッダー エンリッチメントを介して) 維持したいので、すべてのファイルを春以外の 1 つのディレクトリに配置するオプションはありません。

FilePollingFlow を使用すると、上記のプロパティからこれらの Bean インスタンスを作成できますか? このようなことを想像することはできますが、プロパティを Bean インスタンスに渡す方法とインデックスを参照する方法がわかりません。