Как реализовать прокси-брокер ActiveMQ - PullRequest
0 голосов
/ 17 января 2019

Я пытаюсь встроить брокер ActiveMQ 5.x в настольное приложение Java для работы в качестве прокси-сервера, который пересылает сообщения другому брокеру. Отображение localtopic => targettopic.

Скажем, SubA является подписчиком ProxyBroker, SubB является подписчиком RemoteBroker, PubA является издателем ProxyBroker, PubB является издателем RemoteBroker. Независимо от сообщения, полученного в SubA / TOPIC, PubB публикует его в RemoteBroker. И то же самое для SubB запускает PubA для публикации полученного сообщения в ProxyBroker. Этот сценарий вызовет циклический цикл без завершения, так что решение не будет работать. Чтобы это решение было эффективным, если я могу определить, какой клиент является владельцем сообщения, я могу предотвратить эту циклическую проблему, но, к сожалению, я не смог этого сделать.

1 Ответ

0 голосов
/ 30 января 2019

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

ref: Виртуальные темы

...