CODEWITHSUNDEEP
javajmsjava-ee-6jboss7.xhornetq
Boris Pavlović
Boris Pavlović

Reputation: 64632

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?

Upvotes: 3

Views: 5170

Answers (2)

Clebert Suconic
Clebert Suconic

Reputation: 5383

If you're restarting the server, you could remove the paging and data folders (while keeping the bindings).

Upvotes: 2

GeertPt
GeertPt

Reputation: 17854

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

Upvotes: 6

Related Questions