Pollers

Spring 集成还提供 fluent API,用于配置 AbstractPollingEndpoint 实现的 PollerMetadata。可使用 Pollers 构建器工厂配置通用 Bean 定义或从 IntegrationFlowBuilder EIP 方法创建的 Bean 定义,如下例所示:

@Bean(name = PollerMetadata.DEFAULT_POLLER)
public PollerSpec poller() {
    return Pollers.fixedRate(500)
        .errorChannel("myErrors");
}

更多信息,请参见 Javadoc 中的 link:https://docs.spring.io/spring-integration/api/org/springframework/integration/dsl/Pollers.html[Pollers 和 link:https://docs.spring.io/spring-integration/api/org/springframework/integration/dsl/PollerSpec.html[PollerSpec

如果你使用 DSL 将 PollerSpec 构建为 @Bean,则不要在 Bean 定义中调用 getObject() 方法。PollerSpecFactoryBean,从规范生成 PollerMetadata 对象并初始化其所有属性。