Discussion :

[bordi]

Bonjour,

Voila, j'ai fait plusieurs recherches, mais j'ai pas trop trouvé mon bonheur,

Je cherche un exemple de consumer JMS en mode synchrone que je souhaite démarrer dans une webapp.

J'ai vu de tout en mode asynchrone avec onMessage utilisant l'interface MessageListener dans un listener, dans le web.xml, le provider jms appelant la méthode onMessage en multithread. Ce qui ne me va pas.

J'ai rien sur un mode synchrone, hors il est important que je traite les messages en 1 pour 1 en bloquant les autres, dans l'ordre, en FIFO.

j'ai vu quelques rare exemple de mécanisme synchrone et l'utilisation du correlationId en pur java , mais pas dans le contexte d'une webapp (J2EE)

Si quelqu'un à un lien ou un exemple de code, cela me ferait gagner du temps.

Merci d'avance.
JP

[tchize_]

Tu entends quoi par synchrone? Que celui qui a posté le message doit ensuite se mettre en attente jusqu'à ce que le message soit traité? C'est généralement ce qu'un entends par synchrone, mais ça ne correspond pas des masses à ta description.

Si ton problème est de ne traiter qu'un message à la fois, il suffit à ton code de se connecter sur la queue et de traiter chaque message un à un reçu via QueueReceiver.receive()

Note: oublie les listener, eux ils font tout en parallèle, et si t'as beaucoup de messages qui arrivent, tu peux vite avoir une joyeuse explosion de threads

[bordi]

Si ton problème est de ne traiter qu'un message à la fois, il suffit à ton code de se connecter sur la queue et de traiter chaque message un à un reçu via QueueReceiver.receive()

Merci pour votre réponse,

Je me suis mal exprimé, je sais parfaitement traiter des messages en mode asynchrones via les listener.

Mais j'ai besoin de traiter en synchrone, les listener ne sont pas fait pour ca.

je sais comment lire en en synchrone en utilisant la méthode .receive() en me connectant à la queue, mais je ne sais pas comment déployer correctement dans une webapp pour qu'ils soit en ecoute contrairement a l'asyncrhone. en java je n'ai pas de problème.

J'ai pensé à le lancer au démarrage de la webapp avec
ServletContextListener dans la methode contextInitialized(), idem à l'arret
en evitant d'avoir recours à spring.

Exemple:

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
 
 |   // create a queue session
    |   QueueSession queueSession = queueConn.createQueueSession(false,
    |       Session.AUTO_ACKNOWLEDGE);
    |                                                                      
    |   // create a queue receiver
    |   QueueReceiver queueReceiver = queueSession.createReceiver(queue);
    |                                                                      
    |   // start the connection
    |   queueConn.start();
    |                                                                      
    |   // receive a message
    |   TextMessage message = (TextMessage) queueReceiver.receive();
    |

[tchize_]

Il n'y a pas d'avance, tu démarrer un thread qui fait le travail. Maintenant, il y a plein de manière de démarrer ce thread, de la plus basique : un start dans le contextInitializef et un stop en fin de context, aux plus complexes: Spring, Quartz, etc.