Spring Boot со встроенным сервером ActiveMQ Artemis JMS

Я настраиваю встроенный сервер ActiveMQ Artemis, используя приведенный ниже код.

@Override
public void customize(org.apache.activemq.artemis.core.config.Configuration configuration)

Он отлично работает, и я понял, что могу получить доступ позже, как это ->

Queue queue =  embeddedActiveMQ.getActiveMQServer().locateQueue("queue");

QueueControl queueControl = new QueueControlImpl(queue,
                queue.getAddress().toString(),embeddedActiveMQ.getActiveMQServer(),embeddedActiveMQ.getActiveMQServer().getStorageManager()              ,embeddedActiveMQ.getActiveMQServer().getSecurityStore(),embeddedActiveMQ.getActiveMQServer().getAddressSettingsRepository());

queueControl.browse();

Есть проблема сделать так?

Я пытаюсь написать пользовательскую конечную точку для управления очередью вместо использования классического пакета с Jolokia.

Да! большое спасибо

Juan Marques 05.01.2021 19:48
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Полный курс Java для разработчиков веб-сайтов и приложений
Полный курс Java для разработчиков веб-сайтов и приложений
Получите сертификат Java Web и Application Developer, используя наш курс.
0
1
824
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

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

QueueControl queueControl = embeddedActiveMQ.getActiveMQServer().getManagementService().getResource(ResourceNames.QUEUE + "queue");

Это позволит получить QueueControl, который уже был создан для очереди, а не создавать новую с нуля.

Другие вопросы по теме