Discussion :

[osoumayaj]

bonjour,

ce code permet la consommation de message sur une queue, ça marche bien mais voilà le probleme si on fait un shutdown du programme ou du syteme, là ou il tourne le prog au moment ou il lit les message de la queue , un message se perd dans la nature , il est ni dans la queue ni entre les messages sauvegardés, au niveau de "textMessage = (TextMessage) receiver.receive();"
quelqu'un aurai une idée, svp?

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
27
28
29
30
   try{
    Context ictx = null;
    QueueConnection conn = null;
 
    Properties prop = new Properties();
    prop.put(Context.INITIAL_CONTEXT_FACTORY, IntialContext);
    prop.put(fr.dyade.aaa.jndi2.client.NamingContextFactory.JAVA_HOST_PROPERTY, Host);
    prop.put(fr.dyade.aaa.jndi2.client.NamingContextFactory.JAVA_PORT_PROPERTY, Port);
    ictx = new InitialContext(prop);
 
    QueueConnectionFactory qcf = (QueueConnectionFactory) ictx.lookup(
          ConnectionFactory);
 
    conn = qcf.createQueueConnection();
    QueueSession session = conn.createQueueSession(false,Session.AUTO_ACKNOWLEDGE);
    Queue queue = (Queue) ictx.lookup(Queue.toString());
    conn.start();   
    javax.jms.TextMessage textMessage = session.createTextMessage();
    javax.jms.QueueReceiver receiver = session.createReceiver(queue);
    Boolean drap = true;
 
    while(drap){
       trans.begin();
       textMessage = (TextMessage) receiver.receive();
       String message = textMessage.getText();       
       textMessage.clearBody();
      }      
      session.close();
      conn.close();
   }catch (Exception e){}

MERCI

[seb55555]

Lors de l'émission du message, tu peux préciser le mode de persistance.

Code :

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

mEmetteur.send(message, DeliveryMode.NON_PERSISTENT, Message.DEFAULT_PRIORITY, DUREE_VIE_MESSAGE);

Ce message restera présent même si le serveur est arrêté.
Il ne disparaîtra qu'après avoir été consommé.