フローステップとしてのMessageSource

Question

SI-DSLを使用してSIフローを作成していますので、この質問がSi-DSLのみに関連するのかSIおよびSI- DSL。

私のユースケースは、この
ようなものです - キュー からメッセージを取得 - データベーステーブル にメッセージを保存する - 将来 にいくつかの点でいくつかの特定の状態 でメッセージを選択することで、それらのメッセージを取得する - さらに処理メッセージ...

私の問題は3番目のステップです。私はJdbcPollingChannelAdapterをMessageSourceとして使うことができるので、3番目のステップが1番目の場合は簡単です。しかし、私はフローの途中で1つを使用する方法を見つけることができませんでした。だから、DSLの用語で、（dbDataMessageSourceがJdbcPollingChannelAdapterです）私は

IntegrationFlows 
    .from(dbDataMessageSource(), p -> p.poller(Pollers.fixedRate(24, TimeUnit.HOURS))) 

を行うことができます。しかし、私は行うことはできません

代わりに ".handle" 私はゲートウェイを使用しようとしたの

IntegrationFlows 
      .from(Jms.messageDrivenChannelAdapter(...)) 
      .handle(new JdbcOutboundGateway(...) 
      .handle(dbDataMessageSource(), p -> p.poller(Pollers.fixedRate(24, TimeUnit.HOURS))) 

、ブリッジ、handleWithAdapter、しかし注目に値する。

アイデア？

乾杯。

Answer 1

まあ、私が言及したようにこれを行う方法を見つけました。私はJdbcOutboundGatewayを書き直すことができます.JdbcMessageHandlerとJdbcPollingChannelAdapterの両方が含まれています。この最後のものを設定可能にして、ポーリング時間と出力チャンネルを設定します。

少しばかげていますが、うまくいくはずです。

乾杯。

Answer 2

誰もがフローを単一のIntegrationFlowオブジェクトとして宣言しなければならないと考える理由はわかりませんが、誰もチャンネルを複数のチャンネルに分割してチャンネルに接続することを止める者はいません。 1つは.channel("foo")で終わり、もう1つはIntegraitonFlows.from("foo")で始めることができます。それはあなたがそのチャネルを省略し、両方のフローを1つに接続できるように見えますが。

IntegrationFlowは、コード数を最小限に抑えるだけで、いくつかのボイラープレートスニペットを実際には省略できます。しかし、あなたのロジックにチャネルが必要な場合、またはいくつかの段階がある場合は、結果を分割して楽しむことができます。

だから、あなたのロジックは次のようである：

キューとDB内ストアから読み

• 。それは1つですIntegrationFlow
• dbDataMessageSource()とDBをポーリングします。別の独立した流れ。

Core Spring Integrationについて詳しくは、こちらをご覧ください。 Java DSLは設定を単純化しようとしていますが、それでもSI Coreの同じchannel -> endpoint -> handlerの原則に従います。