轮询器

Spring 集成还提供了一个 Fluent API,允许您配置实现。 您可以使用 builder Factory 配置常见的 bean 定义或通过 EIP 方法创建的 bean 定义,如下例所示:PollerMetadataAbstractPollingEndpointPollersIntegrationFlowBuilderspring-doc.cn

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

有关更多信息,请参见 Javadoc 中的 PollersPollerSpecspring-doc.cn

如果使用 DSL 将 a 构造为 ,请不要在 Bean 定义中调用该方法。 这是从规范生成对象并初始化其所有属性的 a。PollerSpec@BeangetObject()PollerSpecFactoryBeanPollerMetadata