javajmsjava-ee-6jboss7.xhornetq

How to clean HornetQ messaging journal before/after performing a test?


There's an Arquillian integration test using JMS HornetQ with persisted messages. Some test leave the messaging journal filled with unhandled messages that break other tests expecting no data.

Is there a way of telling JMS to clean its messaging journal before or after executing a test?


Solution

  • This does not exist in the JMS API itself, but there's a method 'removeMessages(filter)' in the HornetQ QueueControl management object. This method can be found in the JMX Bean for the Queue, but I wouldn't know how to get that in Arquillian.

    Luckily, you can invoke management operations via the 'hornetq.management' queue. See http://docs.jboss.org/hornetq/2.2.5.Final/user-manual/en/html/management.html. In practice, the following should work:

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