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();
} |