Spring統合によるFTPファイルアップロード成功メッセージの送信

Question

JdbcOutboundGatewayへのメッセージの送信を、FTPファイル転送が成功した場合にのみ行う方法を教えてください。

私は以下のIntegrationFlowを持っています。 FTPサーバーにファイルをアップロードしています。しかし、その後、ファイルが正常にアップロードされたことをDBに書き込むか、FTPアップロードで失敗した場合にレコードを更新する必要があります。私はファイル転送の成功のDB更新を開始する方法を考え出すのに困っています。どこでも私はフローを継続しようとしますが、それは単なる「一方向」であるという例外をスローします。

• ftpPropsは
• ftpSessionFactoryFactoryは値からすべての様々なFtpSessionFactoryオブジェクトを構築し、メッセージがFTPを介して送信することが必要に配置されているチャネルは、様々なFTPセットアップ
• outboundMessagesのためのすべての設定値を含みます
  ：ルータは、ヘッダ値

検査フローを通じてにメッセージを送信するかを決定することをconfigファイルに

@Bean 
public IntegrationFlow fromOutboundChannelToFtp(OutboundConfigurationProperties ftpProps, 
               @Qualifier(OUTBOUND_CHANNEL) MessageChannel outboundMessages, 
               @Qualifier(FTP_SESSION_FACTORY_FACTORY) FtpSessionFactoryFactory ftpSessionFactoryFactory) { 
    return IntegrationFlows.from(outboundMessages) 
      .route(RECEIVER_HEADER_SPEL, mapping -> { 
       for (String receiverId : ftpProps.getFtp().keySet()) { 
        mapping.subFlowMapping(receiverId, sf -> { 
         sf.handleWithAdapter(adapter -> 
          adapter.ftp(ftpSessionFactoryFactory.getFactory(receiverId)) 
          .fileNameExpression(FILENAME_HEADER_SPEL) 
          .autoCreateDirectory(true) 
          .remoteDirectory(ftpProps.getValue(receiverId, FtpProp.DIRECTORY)) 
         ); 
        }); 
       } 
      }) 
      .get(); 
} 

Answer 1

outboundMessagesをパブリッシュ/サブスクライブチャネルにし、JDBCアダプタを使用して2番目のフローをサブスクライブします。ルーターおよびjdbcアダプターのコンシューマーのorderプロパティーを正しい順序で呼び出されるように設定します。

デフォルトでは、最初のコンシューマが失敗した場合、2番目のコンシューマは呼び出されません。

フローエントリポイント（チャネルの上流）でエラーチャネルを使用して、障害を処理します。

また、ExpressionEvaluatingMessageHandlerAdviceをftpアダプタに追加し、successチャネルにJDBCアダプタフローを追加し、failureチャネルに異なる更新フローを追加します。