[hornetq-commits] JBoss hornetq SVN: r8564 - trunk/tests/src/org/hornetq/tests/stress/journal.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-12-04 12:37:55 -0500 (Fri, 04 Dec 2009)
New Revision: 8564

Modified:
   trunk/tests/src/org/hornetq/tests/stress/journal/MultiThreadConsumerStressTest.java
Log:
Fixing test

Modified: trunk/tests/src/org/hornetq/tests/stress/journal/MultiThreadConsumerStressTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/stress/journal/MultiThreadConsumerStressTest.java	2009-12-04 17:29:30 UTC (rev 8563)
+++ trunk/tests/src/org/hornetq/tests/stress/journal/MultiThreadConsumerStressTest.java	2009-12-04 17:37:55 UTC (rev 8564)
@@ -69,6 +69,18 @@
       int consumeMessage = (int) (produceMessage * 0.9);
       int commitIntervalConsume = 100;
       
+      ClientSession session = sf.createSession(false, false);
+      session.createQueue("compact", "compact-queue", true);
+      
+      ClientProducer producer = session.createProducer("compact");
+      
+      for (int i = 0 ; i < 100; i++)
+      {
+         producer.send(session.createClientMessage(true));
+      }
+      
+      session.commit();
+      
       // Number of messages expected to be received after restart
       int numberOfMessagesExpected = (produceMessage - consumeMessage) * numberOfConsumers;
 
@@ -123,9 +135,9 @@
          ClientMessage msg = consumer.receive(5000);
          assertNotNull(msg);
          
-         if (i % 100 == 0)
+         if (i % 1000 == 0)
          {
-            System.out.println("Received #" + i + "  on thread after start");
+            System.out.println("Received #" + i + "  on thread before end");
          }
          msg.acknowledge();
       }
@@ -165,7 +177,7 @@
       config.setJournalFileSize(ConfigurationImpl.DEFAULT_JOURNAL_FILE_SIZE);
       config.setJournalMinFiles(ConfigurationImpl.DEFAULT_JOURNAL_MIN_FILES);
 
-      config.setJournalCompactMinFiles(0);
+      config.setJournalCompactMinFiles(2);
       config.setJournalCompactPercentage(50);
 
       server = createServer(true, config);
@@ -254,9 +266,9 @@
                {
                   session.commit();
                }
-               if (i % 100 == 0)
+               if (i % 1000 == 0)
                {
-                  System.out.println(Thread.currentThread().getName() + "::received #" + i);
+                  //System.out.println(Thread.currentThread().getName() + "::received #" + i);
                }
                ClientMessage msg = session.createClientMessage(true);               
                prod.send(msg);
@@ -314,9 +326,9 @@
                {
                   session.commit();
                }
-               if (i % 100 == 0)
+               if (i % 1000 == 0)
                {
-                  System.out.println(Thread.currentThread().getName() + "::sent #" + i);
+                  //System.out.println(Thread.currentThread().getName() + "::sent #" + i);
                }
             }