java-dslを使用してキューチャネルにポーラーを指定するにはどうすればよいですか？

Question

java-dslを使用してキューチャネルからメッセージを消費しますが、Integrations.fromにはポーラーを指定できる署名がありません。

どうすればこの問題を解決できますか？

例：

@Bean 
IntegrationFlow flow() { 
    return IntegrationFlows.from(this.channel()) 
         .handle(...) 
         .get(); 
} 

@Bean 
MessageChannel channel() { 
    return MessageChannels.queue().get(); 
} 

Answer 1

まあ、実際には、ポーラーのプロパティを提供するために、エンドポイントの責任です。

あなたがXML設定に精通している場合は、<queue>からポーリングすることを覚えておく必要があり、我々は<service-activator>ため<poller>サブ要素を設定する必要がありますなど

同じアプローチは、同様にJavaのDSLに適用されます。次のエンドポイント定義は、所望のpollerにする必要があります： - それは無視されます何らかの理由で

IntegrationFlows.from(this.channel()) 
        .handle(..., e -> e.poller(Pollers...)) 
        .get(); 

Answer 2

私はアルテムが説明するように、エンドポイントの定義にポーラーを設定するいくつかの理由でトラブルがありました。常にデフォルトのポーラーを設定することができます。これは私のために働いた：

@Bean(name = PollerMetadata.DEFAULT_POLLER) 
public PollerMetadata poller() { 
    return Pollers.fixedRate(500).get(); 
}