ページングされたhttpリソースにアクセスする統合フロー

Question

私は次のように完全にページングされたリソースを消費しようとしていますが、私のaproachはStackOverflowExceptionを発生させています。 これは何か手掛かりですか？または別の方法ですか？

例：https://gist.github.com/daniel-frank/a88fa4553ed34c348528f51d33c3733b

Answer 1

OK。私は今参照してください。私は、問題を示すために、あなたの再帰的なコードを単純化してみましょう：

private IntegrationFlow getPageFlow() { 
     return f -> f 
       .publishSubscribeChannel(ps -> ps 
         .subscribe(this.nextPageFlow()) 
       ); 
    } 


private IntegrationFlow nextPageFlow() { 
     return f -> f 
       .publishSubscribeChannel(ps -> ps 
         .subscribe(this.getPageFlow()) 
       ); 
} 

だから、技術的に我々はメモリ内にこのような構造を持っていますので、上の

getPageFlow 
    nextPageFlow 
     getPageFlow 
      nextPageFlow 
       getPageFlow 

とを。

また、.subscribe(this.nextPageFlow())の新しいインスタンスはIntegrationFlowという新しいインスタンスを作成しますが、論理的には1つしかありません。

IntegrationFlowAdapterインプリメントで豆を宣言することはできませんが、とにかくStackOverflowExceptionではできません。

私があなたのアプローチで問題として見るものは、MessageChannel抽象化の欠如です。

どこでもpublishSubscribeChannelを使用していますが、フロー内の明示的なチャネル定義によって論理を区別することができます。

再帰を壊し、私はこのように作ると思い、可能な限りあなたの解決に近づくように、コードを保つために：、あなたはまだ再帰を持っているが、それは実行時にすでにでしょう。もちろん、

private IntegrationFlow getPageFlow() { 
     return f -> f 
       .channel("pageServiceChannel") 
       .handle(Http 
          .outboundGateway("https://jobs.github.com/positions.json?description={description}&page={page}") 
... 

    private IntegrationFlow nextPageFlow() { 
     return f -> f 
       .filter("!payload.isEmpty()") 
       .enrichHeaders(e -> e.headerExpression("page", "headers.getOrDefault('page', 0) + 1", true)) 
       .channel("pageServiceChannel"); 
    } 

を論理的。