long timeout = System.currentTimeMillis() + 5000;
while (timeout > System.currentTimeMillis() && queueExpiry.getMessageCount() != numberOfMessages)
{
// What the Expiry Scan would be doing
myQueue.expireReferences();
Thread.sleep(50);
}
assertEquals(50, queueExpiry.getMessageCount());