Envoi de message avec JMS
Hello,
Je suis en train de mettre en place une communication JMS entre un Webservice et un client lourd Swing.
J'ai constaté un comportement un peu étrange de JMS. Après la réception de la commande depuis le webservice, j'envoie mon message puis attend artificiellement quelques secondes avec un Thread.sleep(...) avant de répondre. J'ai constaté que le message JMS ne partait jamais vers mon client lourd avant la fin du Thread.sleep(...). J'ai pourtant essayé d'attendre jusqu'à une minute mais rien ne part. Est-ce que c'est normal ?
Voici la portion de code qui s'occupe de l'envoie. PS : c'est du prototype alors no comment sur les valeurs de retour et autre dégueulasserie :D
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
|
public int connect(String encoder) {
connectionCommand = null;
try {
Context context = new InitialContext();
ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("ConnectionFactory");
Connection connection = connectionFactory.createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = (Destination) context.lookup("queue/StockValue");
MessageProducer producer = session.createProducer(destination);
ObjectMessage message = session.createObjectMessage();
message.setObject(new ConnectionCommand(encoder));
producer.send(message);
producer.close();
session.close();
connection.close();
} catch (Exception e) {
e.printStackTrace();
System.out.println(e.toString());
return 666;
}
int retry = 20;
while(getConnectionCommand() == null && retry > 0) {
try {
Thread.sleep(200);
} catch(InterruptedException e) {
e.printStackTrace();
return 666;
}
retry--;
}
if(getConnectionCommand() == null) {
return -1;
} else {
return 0;
}
} |
