Purge Artemis ActiveMQServer queues in Java

Question

我的集成测试中有一个ActiveMQServerImpl的实例，在我的SetUp方法中，我想清除服务器中的所有队列。 我似乎找不到任何可以做到这一点的方法。 出于性能原因，我想避免为每个测试重新创建 Artemis 服务器 bean。 我只是错过了什么吗？

我都试过：

System.out.println(testBroker.locateQueue(new SimpleString(queueName)).deleteAllReferences()); 
System.out.println(testBroker.locateQueue(new SimpleString(queueName)).getMessageCount()); 

和：

((QueueControl)testBroker.getManagementService().getResource(ResourceNames.QUEUE + queueName)).removeMessages(""); 
((QueueControl)testBroker.getManagementService().getResource(ResourceNames.QUEUE + queueName)).countMessages(""); 

两者都显示消息计数没有变化，我继续看到消息通过我的@JMSListener注释方法。

Answer 1

没有 API 调用来清除代理中的所有队列。执行此操作的一种方法是从ActiveMQServerControl中获取所有队列名称，查找队列并调用所有队列deleteAllReferences()，例如：

for (String queueName : server.getActiveMQServerControl().getQueueNames()) {
Queue queue = server.locateQueue(SimpleString.toSimpleString(queueName));
if (queue != null) {
queue.deleteAllReferences();
}
}

确保在执行此代码时停止所有客户端，否则不会删除"正在传递"的消息(即已发送到客户端但尚未被客户端确认的消息)。