Je ne reçois pas de message dans ma JMS

Bonjour,

Je suis en train de mettre en œuvre une application basée sur JMS, tout ce passe bien, comme il faut, pas d'erreur, pas d'exception, sauf que le message envoyé par le client producteur, n'est pas reçu pas le deuxième client consommateur.

Voici le code du premier client (Producteur) :

Code:

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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
    import javax.jms.*;
    import javax.naming.*;
 
    public class Producteur {
 
        public static void main(String[] args) {
 
            try{
 
                System.out.println("Démarage de l'application ...");
 
                Context ctx = new InitialContext();
                System.out.println("Initialiser le contexte ...");
 
                ConnectionFactory fabrique = (ConnectionFactory)ctx.lookup("MonFournisseur");
                System.out.println("fabrique créée ...");
 
                Destination destination = (Destination)ctx.lookup("MaFile");
                System.out.println("Destination localisée ...");
 
                Connection connexion = fabrique.createConnection();
                System.out.println("Connexion établie ...");
 
                Session session = connexion.createSession(true, Session.AUTO_ACKNOWLEDGE);
                System.out.println("Session créée ...");
 
                MessageProducer envoi = session.createProducer(destination);
                System.out.println("Producteur créé ...");
 
                TextMessage message = session.createTextMessage();
                message.setText("Bonjour, je suis un test de message driven");
                envoi.send(message);
                System.out.println("Message envoyé : " +message );
 
                session.close();
                System.out.println("Session fermée ...");
 
                connexion.close();
                System.out.println("Connexion fermée ...");
 
            }catch(Exception e){
                System.out.println("erreur : " + e.getMessage());
            }
        }
    }

Quand je le lance, j'ai l'affichage suivant :

Démarage de l'application ...
Initialiser le contexte ...
fabrique créée ...
Destination localisée ...
Connexion établie ...
Session créée ...
Producteur créé ...
Message envoyé :
Text: Bonjour, je suis un test de message driven
Class: com.sun.messaging.jmq.jmsclient.TextMessageImpl
getJMSMessageID(): ID:41-10.63.44.174(82:c:e7:de:bd:f0)-2989-1244123873356
getJMSTimestamp(): 1244123873356
getJMSCorrelationID(): null
JMSReplyTo: null
JMSDestination: MaFilePhysique
getJMSDeliveryMode(): PERSISTENT
getJMSRedelivered(): false
getJMSType(): null
getJMSExpiration(): 0
getJMSPriority(): 4
Properties: null
Session fermée ...
Connexion fermée ...

Ceci, bien sûr en plus de quelques messages de type info.
et voici le code du deuxième client (Consommateur) :

Code:

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
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
Tout sélectionner
    import javax.jms.*;
    import javax.naming.*;
 
    public class Consommateur {
 
        public static void main(String[] args) {
 
            try {
                System.out.println("Démarage de l'application ...");
 
                Context ctx = new InitialContext();
                System.out.println("Initialiser le contexte ...");
 
                ConnectionFactory fournisseur = (ConnectionFactory) ctx.lookup("MonFournisseur");
                System.out.println("fabrique créée ...");
 
                Destination destination = (Destination) ctx.lookup("MaFile");
                System.out.println("Destination localisée ...");
 
                Connection connexion = fournisseur.createConnection();
                System.out.println("Connexion établie ...");
 
                Session session = connexion.createSession(false, Session.AUTO_ACKNOWLEDGE);
                System.out.println("Session créée ...");
 
                MessageConsumer réception = session.createConsumer(destination);
                System.out.println("Consommateur créé ...");
 
                connexion.start();
                System.out.println("Connexion lancée ...");
 
                TextMessage message = (TextMessage) réception.receive();
                System.out.println("Message reçu : " + message);
 
                session.close();
                System.out.println("Session fermée ...");
 
                connexion.close();
                System.out.println("Connexion fermée ...");
 
            } catch (NamingException e) {
                System.out.println("Erreur Naming : "+ e.getMessage());
            } catch (JMSException e) {
                System.out.println("Erreur JMS : "+ e.getMessage());
            }
        }
    }

Quand je le lance à son tour, il m'affiche :

Démarage de l'application ...
Initialiser le contexte ...
fabrique créée ...
Destination localisée ...
Connexion établie ...
Session créée ...
Consommateur créé ...
Connexion lancée ...

Et puis il bloque, je pense qu'il attend un message, mais je ne comprends pas pourquoi il ne le reçoit pas du moment où il a été envoyé avec succès(il me semble).

Il serait important de pouvoir vérifier s'il est bien envoyé, mais je ne sais pas comment.
Merci pour tout signe et toute aide.