Author: clebert.suconic(a)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);
}
}