[Camel] Traitement des erreurs dans une route

Bonjour,

Tout d'abord voici ce que je cherche à faire :
Récupérer via FTP des fichiers XML "serveurFTP", les unmarshaller avec JAX-B et exécuter un Processor pour finalement archiver le fichier XML source.

Si traitement OK : archivage du fichier XML dans serveurFTP/ARCHIVE
Si traitement KO : archivage du fichier XML dans serveurFTP/ERREURS


Ci dessous la configuration de ma route Camel :

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18

String ftpOpts= "&delay=10000&recursive=false&filter=#transporteurFilter&delete=true&consumer.bridgeErrorHandler=true";   String routeEnCours = "ftp://"+getUrl()+"/"+getEnCoursDirectory()+"?username="+getUser()+"&password="+getPassword(); String routeErreur = "ftp://"+getUrl()+"/"+getErreurDirectory()+"?username="+getUser()+"&password="+getPassword(); String routeArchive = "ftp://"+getUrl()+"/"+getArchiveDirectory()+"?username="+getUser()+"&password="+getPassword();   // Redirection en cas d'erreur onException(Exception.class) .handled(true) .to(routeErreur);   // Configuration de la route from(routeEnCours+ftpOpts) .unmarshal(dataFormat) .processRef("myProcessor") .to(routeArchive);

---

Le problème rencontré:
En cas d'erreur à n'importe qu'elle étape du workflow je veux que le fichier XML source soit déplacé du repertoire "encours" vers le repertoire "erreur". De même à la fin du traitement le fichier XML doit être déplacé dans "archive". MAIS selon à qu'elle étape on se situe on perd la notion de "fichier XML source", avant le unmarshalling on a un Stream, après le unmarshalling on a un objet Java, etc... Du coup ma stratégie me parait compromise.

Avez vous une idée de comment procéder ? :calim2:

re,

Pour la gestion des erreurs, j'ai réussi à passer par un errorHandler avec l'EIP deadLetterChanel :

Code:

---

errorHandler(deadLetterChannel("ftp://erreursDirUrlEtParams").useOriginalMessage().maximumRedeliveries(1).maximumRedeliveryDelay(5000));

---

Reste le problème de l'archivage..

Salut,

Dans camel tu as la structure .doTry() .doCatch(TonException.class) .doFinally()

Donc tu pourrais faire quelque chose du genre :

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24

from("direct:start") .doTry() // tu sauvegarde ton fichier dans le header .setHeader("MonFichier", body()) .unmarshal(dataFormat) .processRef("myProcessor") .setHeader("Archivage", "OK") .doCatch(Exception.class) .setHeader("Archivage", "KO") .doFinally() // tu remets le fichier dans ton body pour le déplacer dans ta route .setBody(header("MonFichier") .to(routeArchivage) .end();   from(routeArchivage) .choice() .when(header("Archivage").isEqualTo("OK")) // déplacer ton fichier vers repertoire OK .otherwise() // déplacer ton fichier vers répertoire KO .endChoice() .end();

---

Merci Carhiboux pour tes indications, c'est en effet une solution d'enrichir le message avec le body et le résultat d’exécution.

La solution que j'ai adopté est l'ajout de deux options dans from(ftp:// .......), à savoir :
- move = nom d'un répertoire de sauvegarde si traitement OK
- moveFailed= nom d'un répertoire de sauvegarde si traitement KO

Du coup pas besoin de traiter les cas d'erreurs ou d'encapsuler des informations supplémentaires.

Si ca peut servir, voilà le rendu

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15

String ftpOptions = "&delay=10000&recursive=false&filter=#myFilter&move=getArchiveDirectory() +"/${date:now:yyyyMMdd}/${file:name.noext}-${date:now:yyyyMMddHHmmssSSS}.${file:ext}&moveFailed=getErreurDirectory()+ "/${file:name.noext}-${date:now:yyyyMMddHHmmssSSS}.${file:ext}" +"&readLock=changed";   // Récupération des types XML pour convertion JaxbDataFormat dataFormat = new JaxbDataFormat(PACKAGE_BEANS_JAXB); dataFormat.setPrettyPrint(true);   // Configuration de la route from(getEndPointEnCours()+ftpOptions) .unmarshal(dataFormat) .processRef("myProcessor") .end();

---