例外クラスに基づいてファイルを別のフォルダに移動します。

Question

エラーに基づいてFTPルート内のファイルを別のディレクトリに移動する方法はありますか？

from("sftp://XXX@safsdf.de/dir/?delay=2s&move=done&moveFailed=failImport") 
     .split() 
     .body() 
     .process(e -> { 
      String fileName = (String) e.getIn().getHeader(Exchange.FILE_NAME); 
      // do some magic which could throw a exception 
     }) 
     .log("Imported file ${file:name} completely."); 

Answer 1

それはonExceptionをしてアーカイブすることが私の、のtry-catch-最終的またはカスタムファイル処理戦略が、それのどれも本当に便利です。

私はこの単純なコードを思い付いた：

@Override 
public void configure() throws Exception { 
    errorHandler(loggingErrorHandler(logger)); 
    from("sftp://XXX@safsdf.de/dir/?delay=2s&move=${in.header.outDirectory}&moveFailed=failImport") 
      .process(exchange -> exchange.setProperty(originalMessage, exchange.getIn())) 
      .split() 
      .body() 
      .process(e -> { 
       String fileName = (String) e.getIn().getHeader(Exchange.FILE_NAME); 
       Message origMsg = (Message) e.getProperty(originalMessage); 
       try { 
        // do what ever 
        origMsg.setHeader(outDirectory, "done/" + fileName); 
       } catch (KaboomException ex) { 
        origMsg.setHeader(outDirectory, "retry/" + fileName); 
       } 
      }) 
      .log("Imported file ${file:name} completely."); 

} 

その重要な元のメッセージにヘッダを設定します。

Answer 2

キャメルのonExceptionハンドラを確認してください。特定の例外をキャッチし、それに応じてルーティングすることができます。また、エラー処理をCamelのルートでもっと内側にしたい場合は、try-catch-like構文もあります。

onException(BadThingHappenedException.class).to(file:///errorFolder) 

ドキュメント：

onException

try-catch-finally

Custom file processing strategy