Comment rechercher un message particulier dans la file d'attente JMS

Question

J'envoie des messages à une file d'attente JMS. Quels sont les moyens possibles de rechercher un message particulier dans une file d'attente à consommer?

J'ai essayé de la façon suivante: Je suis en train de l'JMSCorrelationID tout en envoyant un message à la file d'attente:

public void createDQueue(String queuename, String json, Integer userid) { 
      try { 

       QueueSession.AUTO_ACKNOWLEDGE); 
       Queue queue = session.createQueue(queuename); 
       ObjectMessage objectMessage = session.createObjectMessage(); 
       objectMessage.setJMSCorrelationID(String.valueOf(userid)); 
       objectMessage.setObject(json); 
       session.createSender(queue).send(objectMessage); 
       session.close(); 
       connection.close(); 
      }catch(Exception e){ 
       e.printStackTrace(); 
      } 
     } 

Dans le code de la consommation, je veux transmettre ce message particulier sur la base JMSCorrelationID. Je ne suis pas en mesure d'obtenir ce message particulier. Pouvez-vous proposer une solution?

public void getSpecificMessage(String queuename, Integer userid) { 

     try { 
      QueueConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616"); 
       ((ActiveMQConnectionFactory) connectionFactory).setUseAsyncSend(true); 
       QueueConnection connection = connectionFactory.createQueueConnection(); 
       connection.start(); 
       QueueSession session = connection.createQueueSession(false, 
        QueueSession.AUTO_ACKNOWLEDGE); 
       String id = String.valueOf(userid); 
      Queue queue = session.createQueue(queuename); 
      QueueReceiver receiver = session.createReceiver(queue, "JMSCorrelationID="+id); 
      Message message = receiver.receive();    
     } catch (JMSException e) {    
      e.printStackTrace(); 
     } 
     } 

Answer 1

Votre premier problème est que vous essayez de penser au courtier de messages en tant que base de données, vous devez toujours vous rappeler ce morceau sage conseil, « Un courtier de messages n'est pas une base de données ». Il existe certaines limites quant à la profondeur d'un navigateur de client ou de file d'attente dans une destination avant que le courtier n'envoie plus de messages à partir du disque, vous devez donc vérifier votre profondeur et voir si son paramètre maxPageSize ajuster au besoin, mais rappelez-vous que les messages envoyés restent en mémoire jusqu'à leur consommation.

Answer 2

Juste envelopper l'identifiant entre guillemets simples

"JMSCorrelationID='"+id+"'" 

Cette fonctionnalité est recommandé de ne pas utiliser, il y a beaucoup plus de complications comme l'a expliqué Tim, mais si vous voulez obsolutely travailler avec elle faire le changement

Answer 3

Vous pouvez rechercher des messages à l'aide du MeessageID d'un message. Ce serait rapide car les fournisseurs de messagerie indexent les messages sur l'identifiant du message. Mais rappelez-vous que l'objectif premier de l'utilisation d'un fournisseur de messagerie est de connecter les applications de manière indépendante du temps. L'application réceptrice doit recevoir des messages dès que possible. Si les messages s'accumulent dans une file d'attente, cela indique un problème qui doit être résolu.