Discussion :

[leminipouce]

Bonjour à tous,

Je ne suis pas bien sûr d'être dans le bon forum, mais je n'en trouve pas qui se rapproche de Camel... j'ai pensé qu'ici...Bref !

J'ai un WS qui doit envoyer un message à Camel pour que celui-ci renvoie vers un service métier.
Il s'agît d'un échange InOut.
Le WS service reçoit 2 paramètres (que je lis sans problème) et doit les renvoyer tous les 2 au service métier via Camel.

J'ai donc le code ci-dessous :

Code :

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

1
2
3
4
5
6
7
8
9
10
			// Envoie du message à Camel pour redirection vers le service
			// métier.
			ProducerTemplate template = context.createProducerTemplate();
 
			List<Object> params = new ArrayList<Object>();
			params.add(10); 
			params.add("toto");
 
			result = template.requestBody("direct:metafluxMessage", // C'est ici la ligne des logs : fr.gouv.agriculture.metaflux.services.impl.MetafluxWSImpl.initTraitement(MetafluxWSImpl.java:61)
					params, TraitementFluxGlobal.class);

Avec la déclaration de route suivante :

Code :

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

1
2
3
4
5
6
				from("direct:metafluxMessage").to("direct:initTraitementGlobal");
				// TODO utiliser l'interface ci-dessous. --> Voir comment
				// utiliser Spring pour faire le mapping avec l'implémentation
				from("direct:initTraitementGlobal").bean(
						ServiceMetafluxImpl.class,
						 "initTraitement(int, String)");

Et la trace d'erreur suivante quand je passe sur "template.requestBody" :

Code :

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

'initTraitement d'

Bien sûr, si je ne passe qu'un seul paramètre à Camel, donc sans la liste, et que mon service métier n'attend qu'un seul paramètre (String ou int, peu importe), tout marche, et j'ai bien mon aller-retour.

J'ai un peu du mal à comprendre, d'autant que l'idée de la liste vient directement du livre "Camel in Action", rédigé par les développeurs de Camel !

Bref, si l'un de vous a des idées pour m'aider à avancer sur le sujet, je suis preneur.

Par avance, Merci.

[leminipouce]

Bon...

J'ai pas trouvé la solution exacte au problème, mais j'ai au moins trouvé un contournement qui me semble propre.
Donc si ça peut aider quelqu'un...

Voici la déclaration d'une route (notez que je renvoie vers une méthode qui attend pour seul et unique paramètre un Message)

Code :

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

1
2
3
		// Route pour l'initialisation des traitements élémentaires
		from(CamelRoutes.DIRECT_INIT_TRAITEMENT_ELEMENTAIRE.getRouteUri()).to(
				BEAN_SERVICE_METAFLUX + METHOD + "initTraitement(Message)");

Et voici la méthode du bean vers lequel est effectué la redirection :

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
19
20
21
22
23
24
25
26
27
28
29
	/**
         * @see fr.gouv.agriculture.metaflux.services.ServiceMetaflux#initTraitement(Exchange)
         */
	public TraitementFluxElementaire initTraitement(Message messageIn)
			throws TraitementUnknownException,
			TraitementNotElementaireException, TraitementNotRunningException {
		LOGGER.trace("Initialisation du traitement elementaire");
 
		@SuppressWarnings("unchecked")
		Map<MessageParams, Object> params = messageIn.getBody(Map.class);
		int idFluxElementaire = (Integer) params
				.get(MessageParams.ID_FLUX_ELEMENTAIRE);
		TraitementFluxGlobal traitementFluxGlobal = (TraitementFluxGlobal) params
				.get(MessageParams.TRAITEMENT_FLUX_GLOBAL);
 
		LOGGER.trace("\tTraitement elementaire n°" + idFluxElementaire
				+ "\n\tTraitement global parent n°"
				+ traitementFluxGlobal.getIdFlux());
 
		// TODO Supprimer ce bouchon pour faire quelque chose d'utile
		TraitementFluxElementaire traitementFluxElementaire = new TraitementFluxElementaire(
				idFluxElementaire, 2 * idFluxElementaire, traitementFluxGlobal);
		traitementFluxGlobal.getListeFluxElementaires().add(
				traitementFluxElementaire);
 
		LOGGER.info("Fin d'initialisation du traitement elementaire n°"
				+ idFluxElementaire);
		return traitementFluxElementaire;
	}

Les paramètres sont récupérés dans une Map qui est le "body" de mon "org.apache.camel.Message".

En espérant que ça aidera...