Контрольная очередь с использованием Java

Question

Я пытаюсь контролировать очередь без использования каких-либо API, таких как Hermes или GEMS, т. Е. Я хочу использовать только JAVA. Поэтому для того, чтобы просмотреть проверку очереди, т.е. если сообщение достигло очереди или нет без потребляя сообщение я написал ниже фрагмент кода:

javax.jms.QueueBrowser browser = session.createBrowser(queue); 

     Enumeration msgs = browser.getEnumeration(); 

     int Count=0; 

     while(msgs.hasMoreElements()) 
     { 
      message = (javax.jms.Message)msgs.nextElement(); 
      System.out.println("Message"+message); 
      Count++; 
     } 

Однако, когда я публикую сообщения в очереди она не отображается результат. Я проверял, что сообщения попадают в очередь, и они потребляются приемником. Так как этот подход не работал, я думал использовать другой подход, который подсчитывает числоOfMessages, получаемое в очереди до и после. Поэтому я использовал приведенный ниже код кода

QueueInfo q= new QueueInfo(queueName); 
    long l=q.getInTransitMessageCount(); 
    System.out.println("In transit Mesasge Count="+l+"\n"); 

Но это также не работает. Любое предложение или пояснение для решения этой проблемы было бы высоко оценено. Обратите внимание, что в коде отсутствует ошибка компиляции, и все необходимые классы импортируются.

Answer 1

Ваш браузер, как представляется, прав .. Проверьте, передаете ли вы правильный аргумент в очереди .. или просто отлаживаете и видите, почему этот цикл не выполняется?

Answer 2

QueueBrowser не должен предоставлять вам снимок. ЕСЛИ у вас есть другие потребители в очереди, тогда они будут истощать его, так что возможно, что их снимают. Сначала попробуйте отключить своего потребителя, чтобы узнать, что произойдет. См [1]

[1] http://docs.oracle.com/javaee/1.3/api/javax/jms/QueueBrowser.html

Answer 3

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

Когда мы наблюдаем за активной очередью сообщений, мы обеспокоены только наличием сообщений в очереди, так как это означает, что потребитель остановился или не потребляет достаточно быстро.

Если вы пытаетесь подсчитать проходящие сообщения, вам необходимо перехватить сообщения (т. Е. Сами их использовать и отправить в другую очередь).

Возможно, вам понадобится дополнительная информация о том, что вы действительно хотите.