轮询器
Spring Integration 还提供了一个流畅的 API,允许您为 AbstractPollingEndpoint 实现配置 PollerMetadata。您可以使用 Pollers 构建器工厂来配置常见的 bean 定义,或者那些从 IntegrationFlowBuilder EIP 方法创建的定义,如以下示例所示:
@Bean(name = PollerMetadata.DEFAULT_POLLER)
public PollerSpec poller() {
return Pollers.fixedRate(500)
.errorChannel("myErrors");
}
有关更多信息,请参阅 Javadoc 中的 Pollers 和 PollerSpec。
如果您使用 DSL 将 PollerSpec 构建为一个 @Bean,请不要在 bean 定义中调用 getObject() 方法。PollerSpec 是一个 FactoryBean,它根据规范生成 PollerMetadata 对象并初始化其所有属性。