[hornetq-commits] JBoss hornetq SVN: r8212 - trunk/tests/src/org/hornetq/tests/integration/journal.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-11-04 11:57:35 -0500 (Wed, 04 Nov 2009)
New Revision: 8212

Modified:
   trunk/tests/src/org/hornetq/tests/integration/journal/MultiThreadCompactorTest.java
Log:
Setting sync to false. This test was not meant to sync on non-transactional.

Modified: trunk/tests/src/org/hornetq/tests/integration/journal/MultiThreadCompactorTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/journal/MultiThreadCompactorTest.java	2009-11-04 16:55:22 UTC (rev 8211)
+++ trunk/tests/src/org/hornetq/tests/integration/journal/MultiThreadCompactorTest.java	2009-11-04 16:57:35 UTC (rev 8212)
@@ -345,7 +345,11 @@
 
          config.setJournalCompactMinFiles(ConfigurationImpl.DEFAULT_JOURNAL_COMPACT_MIN_FILES);
          config.setJournalCompactPercentage(ConfigurationImpl.DEFAULT_JOURNAL_COMPACT_PERCENTAGE);
-
+         
+         // This test is supposed to not sync.. All the ACKs are async, and it was supposed to not sync
+         config.setJournalSyncNonTransactional(false);
+         
+         
          // config.setJournalCompactMinFiles(0);
          // config.setJournalCompactPercentage(0);
 
@@ -442,7 +446,7 @@
                }
                if (i % 100 == 0)
                {
-                  // System.out.println(Thread.currentThread().getName() + "::sent #" + i);
+                  System.out.println(Thread.currentThread().getName() + "::sent #" + i);
                }
                ClientMessage msg = session.createClientMessage(true);
                msg.setBody(ChannelBuffers.wrappedBuffer(new byte[1024]));
@@ -472,7 +476,7 @@
             }
             catch (Throwable e)
             {
-               e.printStackTrace();
+               this.e = e;
             }
          }
       }
@@ -510,7 +514,7 @@
                }
                if (i % 100 == 0)
                {
-                  // System.out.println(Thread.currentThread().getName() + "::received #" + i);
+                  System.out.println(Thread.currentThread().getName() + "::received #" + i);
                }
             }