Discussion :

[totot]

Bonjour,

J'ai une classe qui extend la classe Thread et qui implements l'interface MessageListener
Dans cette classe j'ai donc une méthode run qui fait une connexion au serveur activemq et qui ensuite appel la méthode onMessage
Mon problème est que le statut de mon traitement est null dans ma méthode run alors qu'il est pas null dans ma méthode on message à la fin du traitement

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
public void run{
public void lireMessage(){
//Connexion au serveur Active MQ
receiver.setMessageListener(this);
 
System.out.println(traitement);
}
 
public void onMessage(Message message){
//Traitement
 
traitement = true

Merci de votre aide

[tchize_]

tu peux donner ton code, pas des bribes grammaticalement incorrectes?

[totot]

J'ai donné les méthodes qui sont contenu dans la classe qui extends thread
Il y a liremessage, on message et rubrique qui appelle liremessage

[joel.drigo]

N'empêche, il est impossible de deviner l'enchaînement des appels (où est appelée lireMessage() par exemple, que fait run()...), les variables dont tu parles et leurs caractéristiques (scope, initialisation, synchronisation...), donc le fonctionnement de ton code et donc pourquoi il ne fonctionne pas, sans un code minimum.

Il y a juste une chose qu'on peut éventuellement entrevoir c'est que ton System.out.println() n'affichera très probablement jamais la valeur affectée à traitement dans onMessage().

[tchize_]

J'ai donné les méthodes qui sont contenu dans la classe qui extends thread

Non tu as donné 6 ligne qui n'ont ni queue ni tête.

[totot]

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
public classe LireMessage extends Thread implements MessageListener{
private boolean traitement;
public void lireMessage(){
//Connexion au serveur activeMQ
receiver.setMessageListener(this); // Permet d'appeler la méthode onMessage
}
 
public void onMessage(Message message){
//Traitement du message
 
traitement = true;
System.out.println("Traitement : "+traitement);
 
}
 
public void run(){
lireMessage();
System.out.println("Traitement : "+traitement);
}
}
 
public class Principal{
public void main{
LireMessage lireMessage = new LireMessage();
lireMessage.start();
}

Mon traitement reste à false dans run alors qu'il passe bien à true dans onMessage.

[tchize_]

tu teste la valeur dans ton run immédiatement après avoir enregistré le listener. Les probabilités que la méthode onMessage aie eu le temps de s'exécuter sur les quelques nano secondes qui séparent tes deux instructions sont proche du néant. Le valeur ne passera à true que lorsque tu rentrera dans ton onMessage, chose que se passera dans une futur plus ou moins proche suivant la charge et la réactivité de la queue sur laquelle tu t'es enregistré.
Au passage, tel que présenté, ton Thread ne sert à rien. Il ne fait aucune opération qui nécessiterais un Thread. Tu pourrais appeler directement lireMessage plutôt que démarrer un Thread qui ne fait que l'appeler.