問題タブ [spring-integration-dsl]

データベースからデータを取得し、サービスアクティベーターで簡単な変換を行う単純な DSL を 1 つ作成しました。

queryChannel は jdbc アウトバウンド ゲートウェイであり、sampleConverter はサービス アクティベーターです。

問題は、データベースからデータを取得した後、フローが serviceActivator に送られず、単にデータベースの応答を返すことです。

xml 構成では、以下のようにチェーン内でゲートウェイを呼び出していました。

ここで私が間違っていることを提案してください。前もって感謝します。

フィルターを追加してフローを破棄し、障害後もメイン フローを実行し続け、スプリッターを集約しようとしています。エラーと成功の両方の予想されるタイプは同じです。特定のアグリゲーター ロジックはありません。

破棄チャネルは、分割内の次の項目を実行するためにメイン フローに戻っていません。

ルートとサブフローのマッピングを記述できますが、フィルターを使用してこれを解決しようとするルート -> サブフロー -> ルート -> サブフローで入れ子になりすぎます。検証を実行し、フロー内のすべてのアイテムの分割を続行するためのより良い方法はありますか?

更新 1:

ゲートウェイはリクエストをインターセプトできますが.handle(new MyHandler())、次のアイテムではなくフローが実行されましたsplit()

更新 2: (回答) Artem から

これにより、条件付きスキップが行われ、フローが続行されます。

channelTransacted(true) のときにリスナーコンテナをセットアップして、メッセージを再キューする代わりにデッドレターキューにスローするにはどうすればよいですか? channelTransacted を使用しない場合、すべてが正常に機能し、デッド レター キューにメッセージが表示されます。

編集

これらは依存関係のバージョンです。

トランザクションを外部トランザクション データベース (PlatformTransactionManager) と同期させたいと考えています。リスナーコンテナーに transactionManager(transactionManager) を設定すると、常に再キューイングされます。