Где найти сообщения в HornetQ

Question

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

Answer 1

Вы можете проверить доставку сообщений HornetQ двумя способами.

Подход 1: Простейшее и простой способ, с помощью JConsole, Open JConsole из каталога JDK и выберите hornetQ процесс от локального процесса (я предполагаю, что вы hornetq в локальной машине еще вам нужно включить удаленный JMX) и выберите подключение и перейдите к MBans, как показано на диаграмме ниже. и выберите org.hornetq -> Queue -> JMS -> Your Queue -> Attributes. Два параметра количество сообщений и сообщений добавляемые указывают статус сообщения JMS (примечание здесь вы не можете прочитать сообщения)

подход 2: Hermes JMS, Скачать Hermes JMS (если вы используете Windows 7 скачать 1.15 версия от here). Установите HermesJMS, выполнив банку. После того, как HermesJMS установит выполнение hermes.bat в каталоге bin (если он не запускается, вам нужно отредактировать пакетный файл hermes.bat и добавить set HERMES_CONFIG={valid accessible directory} после set HERMES_HOME).

Теперь настройте Hermes JMS следующим образом.

1. Перейти к действию-> Новая сессия, во всплывающем окне перейдите на вкладку провайдеров в нижней части окна. щелкните правой кнопкой мыши группы классов и выберите группы и введите HornetQ и нажмите «ОК».
2. Развернуть hornetQ и щелкнуть правой кнопкой мыши по библиотеке и выбрать добавить банки добавить все следующие банки после следующих 3 & 4 шага.

3. Среднее время Goto {HermesJMS домашний каталог} \ поставщики создать HermesJMS каталог и скопировать следующие библиотеки из hornetq \ Lib каталог hornetq сервера

   hornetq-core-client.jar 
   hornetq-jms-client.jar 
   hornetq-logging.jar 
   jboss-jms-api.jar 
   jnp-client.jar 
   netty.jar 
   

4. сохранить и перезапустить приложение HermesJMS

5. Factory Connection разделы

   binding = ConnectionFactory 
   initialContextFactory = org.jnp.interfaces.NamingContextFactory 
   providerURL = jnp://localhost:1099 
   urlPkgPrefixes = org.jnp.interfaces:org.jboss.naming 
   

6. Сохраните настройки с именем

7. Щелкните правой кнопкой мыши на сеансах -> новый сеанс, созданный на шаге 6, и выберите пункт «Найти». Он заполнит все очереди JMS.
8. Теперь выберите свою целевую очередь JMS и нажмите кнопку просмотра.

ПРИМЕЧАНИЕ HoentQ не сохраняет сообщение, как только для чтения из вашего слушателя, поэтому, если вам нужно, чтобы увидеть сообщение HermesJMS вам нужно прочитать сообщение после некоторой задержки.