[hornetq-commits] JBoss hornetq SVN: r9500 - trunk/tests/src/org/hornetq/tests/integration/persistence.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-08-03 14:39:46 -0400 (Tue, 03 Aug 2010)
New Revision: 9500

Modified:
   trunk/tests/src/org/hornetq/tests/integration/persistence/DeleteMessagesOnStartupTest.java
Log:
https://jira.jboss.org/browse/HORNETQ-468 - improving the test. Just a tweak

Modified: trunk/tests/src/org/hornetq/tests/integration/persistence/DeleteMessagesOnStartupTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/persistence/DeleteMessagesOnStartupTest.java	2010-08-03 18:31:56 UTC (rev 9499)
+++ trunk/tests/src/org/hornetq/tests/integration/persistence/DeleteMessagesOnStartupTest.java	2010-08-03 18:39:46 UTC (rev 9500)
@@ -61,9 +61,10 @@
 
       journal.storeMessage(msg);
 
-      journal.storeMessage(new ServerMessageImpl(2, 100));
-
-      journal.storeMessage(new ServerMessageImpl(3, 100));
+      for (int i = 2; i < 100; i++)
+      {
+         journal.storeMessage(new ServerMessageImpl(i, 100));
+      }
       
       journal.storeReference(1, 1, true);
 
@@ -77,11 +78,12 @@
 
       journal.loadBindingJournal(new ArrayList<QueueBindingInfo>(), new ArrayList<GroupingInfo>());
       
-      assertEquals(2, deletedMessage.size());
+      assertEquals(98, deletedMessage.size());
       
-      assertEquals(new Long(2), deletedMessage.get(0));
-      
-      assertEquals(new Long(3), deletedMessage.get(1));
+      for (Long messageID : deletedMessage)
+      {
+         assertTrue("messageID = " + messageID, messageID.longValue() >= 2 && messageID <= 99);
+      }
    }
 
    protected JournalStorageManager createJournalStorageManager(Configuration configuration)