首页 文章

在启动spring-integration上动态创建MessageSource

提问于
浏览 1737
1

对于spring-integration项目,假设我有一个包含不同FTP配置值的配置文件 . 每个集合都需要转换为应用程序的MessageSource,以便从各种FTP源进行所有轮询,并将它们插入特定的单个通道 .

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

我需要基本上创建一组MessageSource然后遍历创建的MessageSources,在启动期间将它们全部添加到IntegrationFlow .

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

1 回答

  • 1

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

相关问题