轮询器

Spring 集成还提供了一个 Fluent API，允许您配置PollerMetadata为AbstractPollingEndpoint实现。您可以使用Pollersbuilder factory 配置公共 bean 定义或从IntegrationFlowBuilderEIP 方法，如下例所示：spring-doc.cadn.net.cn

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

看Pollers和PollerSpec在 Javadoc 中了解更多信息。spring-doc.cadn.net.cn

如果使用 DSL 构造PollerSpec作为@Bean，请不要调用getObject()方法。这PollerSpec是一个FactoryBean这会生成PollerMetadataobject 并初始化其所有属性。