首页 文章

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

提问于
浏览 次
1

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

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

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

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

java spring spring-boot spring-integration

1 回答

  • 1

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

    回复于

相关问题