Discussion :

[cocoyot]

Bonjour,
Je souhaite utiliser JMS pour effectuer des traitements longs en parallèle. Savez comment paramétrer mon MDB pour que je puisse lancer maxi 5 traitements (méthode onMessage) en parallèle et que les autres messages restent dans la queue jusqu'à la fin d'un traitement ?
Dois je implémenter moi même le mécanisme ?

Pour info j'utilise JBoss 4.3.

[cocoyot]

J'aurais peut dû poser ma question sur le forum JBoss. J'ai trouvé la réponse toute seule :

Code :

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

1
2
 
@ActivationConfigProperty(propertyName="maxSession", propertyValue="5")

[suzchr]

Salut je cherche à créer un EJB MDB qui me lance des batch en fonction des messages reçu dans le Topic JMS.
Je ne sais pas trop comment m'y prendre !
Pourrais tu me renseigner ?
Merci.

[cocoyot]

Bonjour, voici un exemple avec une file (il suffit de changer les annotations pour un Topic).

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
30
31
32
33
34
35
36
37
38
39
40
 
@MessageDriven(activationConfig = {
		@ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/aipa/tts"),
		@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
		@ActivationConfigProperty(propertyName = "maxSession", propertyValue = "5") })
/**
 * La gestion des transactions n'est pas laissée au container à cause d'un
 * problème de timeout de transaction pendant le process de vocalisation qui
 * peut être très long et les timeout du gestionnaire de transaction de JBoss 
 * claquent
 */
@TransactionManagement(TransactionManagementType.BEAN)
public class TTSJobMDB implements MessageListener {
 
 
       ...
 
        /**
         * Implémentation de {@link MessageListener} <br>
         * Ordre de vocalisation
         */
	public void onMessage(Message message) {
		try {
			final Long ttstextid = message.getLongProperty("textid");
			mLogger.debug("onMessage, ttstextid=" + ttstextid);
			if (null != ttstextid) {
				try {
					performTTS(ttstextid);
				} catch (Exception e) {
 
					mLogger.error("onMessage ERROR", e);
				}
			}
		} catch (Exception e) {
			mLogger.warn("onMessage, error ", e);
		} finally {
 
		}
	}
}

[suzchr]

Merci bcp.
je suis arrivé a faire ce que je voulais.

[schausson]

Bonjour,

J'ai un pb un peu similaire (traitement long à déclencher sur réception d'un message)...J'ai essayé de positionner le timeout sur les transactions (annot JBoss) mais ça ne semble pas fonctionner...

Je me pose la question a propos des transactions de type 'BMT' car dans mon traitement, j'ai plusieurs méthodes qui font de la lecture/ecriture en BD (via hibernate) et il semblerait que la session hibernate expire (liée à la transaction courante ?)...

D'avance merci

[cocoyot]

Ma solution a été de gérer "manuellement" les transactions, de libérer avant le traitement long pour reprendre de suite après.
Je ne suis pas certaine que ce soit la bonne solution ... mais après avoir tout essayer avec les annotations pour allonger les timeout de transaction, je ne voyais pas quoi faire d'autre.

Depuis je suis tombée là dessus : http://docs.jboss.org/ejb3/app-serve...xtensions.html, paragraphe 5.3, où JBoss propose une solution pour lancer des traitements lourd en asynchrone, mais rien est dit sur les transactions ... Je n'ai pas essayé mais c'est peut-être une autre piste.