[hornetq-commits] JBoss hornetq SVN: r8081 - trunk/tests/src/org/hornetq/tests/integration/client.
Author: clebert.suconic(a)jboss.com
Date: 2009-10-12 14:37:50 -0400 (Mon, 12 Oct 2009)
New Revision: 8081
Modified:
trunk/tests/src/org/hornetq/tests/integration/client/CompactingTest.java
Log:
Changing defaults on sync for the test
Modified: trunk/tests/src/org/hornetq/tests/integration/client/CompactingTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/CompactingTest.java 2009-10-12
15:28:06 UTC (rev 8080)
+++ trunk/tests/src/org/hornetq/tests/integration/client/CompactingTest.java 2009-10-12
18:37:50 UTC (rev 8081)
@@ -115,6 +115,7 @@
for (int i = 0; i < 200; i++)
{
System.out.println("Iteration " + i);
+ // Sending non transactionally, so it would test non transactional stuff on the
journal
for (int j = 0; j < 1000; j++)
{
Message msg = session.createClientMessage(true);
@@ -123,6 +124,7 @@
prod.send(msg);
}
+ // I need to guarantee a roundtrip to the server, to make sure everything is
persisted
session.commit();
for (int j = 0; j < 1000; j++)
@@ -132,6 +134,7 @@
msg.acknowledge();
}
+ // I need to guarantee a roundtrip to the server, to make sure everything is
persisted
session.commit();
}
@@ -419,6 +422,7 @@
private void setupServer(JournalType journalType) throws Exception, HornetQException
{
Configuration config = createDefaultConfig();
+ config.setJournalSyncNonTransactional(false);
config.setJournalFileSize(ConfigurationImpl.DEFAULT_JOURNAL_FILE_SIZE);
config.setJournalType(journalType);
@@ -431,6 +435,8 @@
server.start();
sf = createInVMFactory();
+ sf.setBlockOnPersistentSend(false);
+ sf.setBlockOnAcknowledge(false);
ClientSession sess = sf.createSession();