在 Java 中清除 Artemis ActiveMQServer 队列

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();
   }
}

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