[JMS] Récuperer message

Bonjour,

Je développe une application et je souhaite que mon consommateur de message écoute en permanence pour la réception des message:
J'avais fait ceci sauf que je trouve cela moche une boucle infini. Avez-vous une autre solutions?

Code:

---

1 2 3 4

while(true){ Message messageReçu = consumer.receive(); this.onMessage(messageReçu); }

---

Merci de votre aide

Faire un message driven bean ?

Je connait pas du tout

Ne fait surtout pas de while(true) et n'utilise pas receive(), les profs vont te tuer, ils attendent de toi que tu utilises les fonctionnalités asynchrones de JMS.

Justement j'ai essayer ceci mais il se passe rien:

Code:

---

1 2	MessageConsumer receiver = session.createConsumer(destination); receiver.setMessageListener(this);

---

Ma classe implements MessageListener
Sa me détecte pas l'arrivé d'un nouveau message, il faut que je relance mon application or c'est pas ce que je veux

Citation:

---

Envoyé par totot

Je connait pas du tout

---

c'est bête comme tout à faire, pour autant que tu utiliser un serveur javaEE. Il te suffit de créer un bean qui implémente MessageListener et de lui mettre l'annotation MessageDriven, il sera appelé dès arrivée d'un message.

Code:

---

1 2 3 4 5 6 7

@MessageDriven(mappedName="jms/Queue") // queue à écouter public class SimpleMessageBean implements MessageListener { @Resource // si tu en as besoin private MessageDrivenContext mdc; public void onMessage(Message inMessage) { //action }

---

http://docs.oracle.com/javaee/6/tutorial/doc/bnbpo.html

Et si je veux l'utiliser dans des application qui utilise pas J2ee

dans ce cas, si tu es sur une application standalone, et que tu n'utilise pas de filtre, une boucle avec un receive est selon moi tout à fait acceptable. Avec quelques adaptations:

Utiliser la méthode receive prenant un "timeout" en argument, pour ne pas dormir indéfiniment.
Vérifier dans chaque tour de boucle que l'on a pas demandé au thread de s'arrêter.

Mais si je met un timeout, il va pas écouter en parmanence

Citation:

---

Envoyé par totot

Mais si je met un timeout, il va pas écouter en parmanence

---

Et en quoi ce serait un problème? Ton code n'écoute pas en permance, il arrête l'écoute pour traiter un message puis reprends l'écoute là où il s'est arrêter. Je propose d'ajouter un timeout pour pouvoir éventuellement arrêter le programme proprement.

Pardons, je voulais dire que je souhaite pas qu'il s'arrête d'écouté

c'est pour ça que tu met l'appel dans une boucle, pour qu'il reprenne après tes check d'arrêt...

Je fait un while(true) ?

plutot un

Code:

---

1 2	while (! mustStop){ }

---