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

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-09-22 12:36:13 -0400 (Wed, 22 Sep 2010)
New Revision: 9715

Modified:
   trunk/tests/src/org/hornetq/tests/integration/persistence/DeleteMessagesOnStartupTest.java
Log:
Fixing test

Modified: trunk/tests/src/org/hornetq/tests/integration/persistence/DeleteMessagesOnStartupTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/persistence/DeleteMessagesOnStartupTest.java	2010-09-22 15:29:49 UTC (rev 9714)
+++ trunk/tests/src/org/hornetq/tests/integration/persistence/DeleteMessagesOnStartupTest.java	2010-09-22 16:36:13 UTC (rev 9715)
@@ -15,10 +15,8 @@
 
 import java.util.ArrayList;
 import java.util.HashMap;
-import java.util.Map;
 
-import com.arjuna.ats.internal.arjuna.template.HashList;
-
+import org.hornetq.api.core.SimpleString;
 import org.hornetq.core.config.Configuration;
 import org.hornetq.core.persistence.GroupingInfo;
 import org.hornetq.core.persistence.QueueBindingInfo;
@@ -26,8 +24,8 @@
 import org.hornetq.core.server.Queue;
 import org.hornetq.core.server.ServerMessage;
 import org.hornetq.core.server.impl.ServerMessageImpl;
+import org.hornetq.tests.unit.core.postoffice.impl.FakeQueue;
 import org.hornetq.tests.unit.core.server.impl.fakes.FakePostOffice;
-import org.hornetq.tests.util.ServiceTestBase;
 
 /**
  * A DeleteMessagesOnStartupTest
@@ -56,9 +54,13 @@
    public void testDeleteMessagesOnStartup() throws Exception
    {
       createStorage();
-
+      
+      Queue theQueue = new FakeQueue(new SimpleString(""));
+      HashMap<Long, Queue> queues = new HashMap<Long, Queue>();
+      queues.put(100l, theQueue);
+      
       ServerMessage msg = new ServerMessageImpl(1, 100);
-
+      
       journal.storeMessage(msg);
 
       for (int i = 2; i < 100; i++)
@@ -66,18 +68,16 @@
          journal.storeMessage(new ServerMessageImpl(i, 100));
       }
       
-      journal.storeReference(1, 1, true);
+      journal.storeReference(100, 1, true);
 
       journal.stop();
 
       journal.start();
 
-      Map<Long, Queue> queues = new HashMap<Long, Queue>();
-
+      journal.loadBindingJournal(new ArrayList<QueueBindingInfo>(), new ArrayList<GroupingInfo>());
+      
       journal.loadMessageJournal(new FakePostOffice(), null, null, queues, null);
 
-      journal.loadBindingJournal(new ArrayList<QueueBindingInfo>(), new ArrayList<GroupingInfo>());
-      
       assertEquals(98, deletedMessage.size());
       
       for (Long messageID : deletedMessage)
@@ -107,5 +107,6 @@
    // Private -------------------------------------------------------
 
    // Inner classes -------------------------------------------------
+   
 
 }