[hornetq-commits] JBoss hornetq SVN: r8081 - trunk/tests/src/org/hornetq/tests/integration/client.

[do-not-reply at jboss.org]

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