Discussion :

[totot]

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 :

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

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

Merci de votre aide

[tchize_]

Faire un message driven bean ?

[totot]

Je connait pas du tout

[Gugelhupf]

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.

[totot]

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

Code :

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

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

[tchize_]

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 :

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

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

[totot]

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

[tchize_]

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.