輪詢器
Spring Integration 還提供了一個流暢的 API,允許您為 AbstractPollingEndpoint 實現配置 PollerMetadata。您可以使用 Pollers 構建器工廠來配置常見的 Bean 定義或從 IntegrationFlowBuilder EIP 方法建立的 Bean 定義,如以下示例所示
@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 物件並初始化其所有屬性。 |