gpt4 book ai didi

spring-integration - 是否可以为数据源中的每个实体配置轮询器?

转载 作者:行者123 更新时间:2023-12-02 19:12:13 25 4
gpt4 key购买 nike

我正在通过 Spring 集成开发多属性微服务。我从数据库(例如 LOGIN 表)获取每个属性的登录凭据。 LOGIN 表有这些字段; LOGIN.username、LOGIN.pass 和 LOGIN.period(轮询者的周期)。如果我想使用基于 LOGIN.period 字段的不同轮询器配置的微服务,我该怎么做?

    @Bean
public IntegrationFlow start() {
return IntegrationFlows
.from(() -> DAO.getLoginList()) // from a web service.
.split() // splits the each login credentials for each property.
.channel("X_CHANNEL") // subscribes to a channel todo business logic.
.get();
}

是否可以实现一个组件,根据数据库中的 LOGIN.period 值在不同的轮询器配置中进行工作流程?

最佳答案

根据 Artem Bilan 的回答,我实现了 IntegrationFlowContext 和 IntegrationFlow 实例;

    @Autowired
IntegrationFlowContext flowContext;

@Bean
public void setFlowContext() {
List<Login> loginList = DAO.getLoginList(); // a web service
loginList.forEach(e -> {
IntegrationFlow flow = IntegrationFlows.from(() -> e, c -> c.poller(Pollers.fixedRate(e.getPeriod(), TimeUnit.SECONDS, 5)))
.channel("X_CHANNEL")
.get();
flowContext.registration(flow).register();
});
}

关于spring-integration - 是否可以为数据源中的每个实体配置轮询器?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/64122660/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com