Как найти конкретное сообщение в очереди JMS

Question

Я отправляю сообщения в очередь JMS. Каковы возможные способы поиска конкретного сообщения в очереди для потребления?

Я пробовал следующим образом: я устанавливаю JMSCorrelationID при отправке сообщения в очередь:

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

В потребительском коде я хочу получить, что конкретное сообщение на основе JMSCorrelationID. Я не могу получить это сообщение. Можете ли вы предложить решение?

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

Вашей первая проблема заключается в том, что вы пытаетесь думать о брокере сообщений в базе данных, вы должны всегда помнить этот шалфей совет, «Сообщение брокер не является базой данных».

Существуют определенные ограничения в отношении того, насколько глубокий потребитель или браузер очереди может попасть в пункт назначения до того, как брокер не будет размещать больше сообщений с диска, поэтому вам нужно проверить свою глубину и посмотреть, не превышает ли ее значение maxPageSize и при необходимости отрегулируйте, но помните, что сообщения, выгруженные в память, остаются в памяти до тех пор, пока не будут потреблены.

Answer 2

Просто оберните значение идентификатора в одинарные кавычки

"JMSCorrelationID='"+id+"'" 

Эта функция не рекомендуется использовать, есть намного больше осложнений, как объяснена Тима, но если вы хотите obsolutely работу с ним внести изменения

Answer 3

Вы можете искать сообщения, используя сообщение MeessageID. Это было бы быстро, поскольку провайдеры обмена сообщениями индексировали сообщения на идентификаторе сообщения. Есть другой способ поиска на основе CorrelationId, метаданных и т. Д.

Но, пожалуйста, помните, что основной целью использования поставщика сообщений является подключение приложений в автономном режиме. Получающее приложение должно получать сообщения как можно скорее. Если сообщения накапливаются в очереди, это указывает на проблему, которая должна быть устранена.