Discussion :

[Dr_GreenThumb]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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 ?

[Dr_GreenThumb]

re,

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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

Reste le problème de l'archivage..

[Carhiboux]

Salut,

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

Donc tu pourrais faire quelque chose du genre :

Code java :

Sélectionner tout - Visualiser dans une fenêtre à part

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();

[Dr_GreenThumb]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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();