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