ダイレクトチャネルを使用したメッセージスプリッタの後のエラー処理

Question

私はspring integration java dslを使用して電子メールを送信するサービスに取り組んでいます。

私は電子メールに変換される個々のメッセージの集合に分割されたバッチメッセージを持っています。

これらの個々のメッセージのいずれかでエラーが発生した場合、そのバッチ内の他のメッセージは処理されません。

メッセージが例外をスローすると例外が正常に処理され、バッチ内の次のメッセージが処理されるようにフローを設定する方法はありますか？

次のコードは、私が望む機能を実現しますが、これを達成するためのより簡単な方法があれば理想的です。 ：あなたは、そのtrapExceptionオプションで最後handle()定義にExpressionEvaluatingRequestHandlerAdviceを追加することができます

@Bean 
    public MessageChannel individualFlowInputChannel() { 
     return MessageChannels.direct().get(); 
    } 

    @Bean 
    public IntegrationFlow batchFlow() { 
     return f -> f 
      .split() 
      .handle(message -> { 
       try { 
        individualFlowInputChannel().send(message); 
       } catch (Exception e) { 
        e.printStackTrace(); 
       } 
      }); 
    } 

    @Bean 
    public IntegrationFlow individualFlow() { 
     return IntegrationFlows.from(individualFlowInputChannel()) 
      .handle((payload, headers) -> { 
       throw new RuntimeException("BOOM!"); 
      }).get(); 
    } 

Answer 1

：あなたは、「メールを送信」について話している場合一方

/** 
* If true, any exception will be caught and null returned. 
* Default false. 
* @param trapException true to trap Exceptions. 
*/ 
public void setTrapException(boolean trapException) { 

、それは良いことではないでしょう分割されたアイテムごとに別々のスレッドでこれを行うことを検討しますか？この場合、.split()の後にExecutorChannelが救助に来ます！