JMS Producer-Consumer-Observer (PCO)

Question

В JMS есть очереди и темы. Насколько я понимаю, до сих пор очереди лучше всего используются для сценариев производителей/потребителей, где темы могут использоваться для публикации/подписки. Однако в моем сценарии мне нужен способ объединить оба подхода и создать архитектуру производителя-потребителя-наблюдателя.

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

Каков наилучший способ реализовать это, используя комбинацию очередей и/или тем? GUI всегда должен быть уведомлен, но он никогда не должен потреблять что-либо из очереди?

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

Чтобы дать более конкретный пример:

1. У меня есть очередь с пакетами (PACKAGEQUEUE), производимую машиной (PackageProducer)
2. Я работник, который принимает пакет из PACKAGEQUEUE добавляет адрес и затем записывает его в MAILQUEUE (AddressWorker)
3. Другой рабочий обрабатывает MAILQUEUE и отправляет пакеты по почте (MailWorker).
4. После шага 2. когда сообщение записывается в MAILQUEUE, я хочу уведомить об этом графический интерфейс и обновить статус пакета. Разумеется, графический интерфейс не должен потреблять сообщения в MAILQUEUE, только их следует использовать только MailWorker.

Answer 1

Вы можете использовать комбинацию из очереди и темы для своего решения.

Ваше приложение для графического интерфейса пользователя может подписаться на тему, скажем MAILQUEUE_NOTIFICATION. Каждый раз (т. Е. На шаге 2) PackageProducer пишет сообщение MAILQUEUE, копия этого сообщения должна быть опубликована до MAILQUEUE_NOTIFICATION. Поскольку приложение GUI подписалось на эту тему, оно получит эту публикацию, содержащую информацию о статусе пакета. GUI может быть обновлен с содержанием этой публикации.

НТН