使用嵌入式ActiveMQ Artemis JMS服务器的Spring Boot

Question

我正在使用下面的代码自定义嵌入式ActiveMQ Artemis服务器。

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

java prettyprint-override">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();

Answer 1

从技术上讲，这样做并没有什么问题，但是可能有更好的方法来做你想做的事情。例如，要获得QueueControl实例，可以执行如下操作：

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

这将获得已经为队列创建的queueControl，而不是从头创建新的队列。