JMS / Traitements en parallèle

Version imprimable

07/10/2008, 13h12
cocoyot

JMS / Traitements en parallèle

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.
08/10/2008, 16h32
cocoyot
J'aurais peut dû poser ma question sur le forum JBoss. J'ai trouvé la réponse toute seule :
Code:

1 2 @ActivationConfigProperty(propertyName="maxSession", propertyValue="5")
17/12/2008, 10h30
suzchr

Renseignement

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.

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

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
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 {
 
		}
	}
}

17/12/2008, 13h57
suzchr

Merci

Merci bcp.
je suis arrivé a faire ce que je voulais.
09/02/2009, 15h28
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
09/02/2009, 15h58
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.