java - 如何在执行测试之前/之后清理 HornetQ 消息日志？

Question

Arquillian 集成测试使用 JMS HornetQ 和持久化消息。一些测试让消息日志充满了未处理的消息，这些消息破坏了其他不需要数据的测试。

有没有办法告诉 JMS 在执行测试之前或之后清理其消息传递日志？

Answer 1

这在JMS API 本身中并不存在，但是在HornetQ QueueControl 管理对象中有一个方法'removeMessages(filter)'。这个方法可以在队列的 JMX Bean 中找到，但我不知道如何在 Arquillian 中获得它。

幸运的是，您可以通过“hornetq.management”队列调用管理操作。参见 http://docs.jboss.org/hornetq/2.2.5.Final/user-manual/en/html/management.html .在实践中，以下应该起作用:

     Queue managementQueue = HornetQJMSClient.createQueue("hornetq.management");
     QueueRequestor requestor = new QueueRequestor(session, managementQueue);
     Message m = session.createMessage();
     JMSManagementHelper.putOperationInvocation(m,
                                                "jms.queue.exampleQueue",
                                                "removeMessages","*");
     Message reply = requestor.request(m);
     boolean success = JMSManagementHelper.hasOperationSucceeded(reply);