【发布时间】:2019-02-06 18:14:01
【问题描述】:
有一个使用 JMS HornetQ 和持久消息的 Arquillian 集成测试。一些测试使消息日志充满了未处理的消息,这些消息破坏了其他不期望数据的测试。
有没有办法告诉 JMS 在执行测试之前或之后清理其消息传递日志?
【问题讨论】:
标签: java jms java-ee-6 jboss7.x hornetq
有一个使用 JMS HornetQ 和持久消息的 Arquillian 集成测试。一些测试使消息日志充满了未处理的消息,这些消息破坏了其他不期望数据的测试。
有没有办法告诉 JMS 在执行测试之前或之后清理其消息传递日志?
【问题讨论】:
标签: java jms java-ee-6 jboss7.x hornetq
这在 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);
【讨论】:
如果您要重新启动服务器,则可以删除分页和数据文件夹(同时保留绑定)。
【讨论】: