对于spring-integration项目,请说我有一个配置文件,其中包含不同的FTP配置值集。每个集合都需要变成一个MessageSource,应用程序才能从各种FTP源进行所有轮询,并将它们插入特定的单个通道中。

如何遍历每个配置集以在启动时动态创建多个MessageSource并将它们添加到IntegrationFlow?此配置文件可以随时增长/缩小。每次更新配置文件时,更新放入新@Bean对象中并进行生产部署的项目代码绝对不是理想的选择。

我基本上需要创建一组MessageSource,然后遍历创建的MessageSource,并将它们全部在启动过程中添加到IntegrationFlow中。

注意:不需要“即时”添加和删除MessageSource,只需在应用程序启动时选择新的配置值即可。

最佳答案

从Spring Integration Java DSL 1.2开始,有手册IntegrationFlow registration functionality。因此,您必须迭代配置,创建IntegrationFlow定义并为每个定义调用integrationFlowContext.registration(myFlow)

关于java - 在启动Spring集成时动态创建MessageSource,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/41368336/

10-10 14:57