[jboss-cvs] JBoss Messaging SVN: r5622 - in branches/Branch_Failover_Page: tests/src/org/jboss/messaging/tests/integration/paging and 1 other directory.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-01-13 12:32:39 -0500 (Tue, 13 Jan 2009)
New Revision: 5622

Modified:
   branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/paging/impl/PagingStoreImpl.java
   branches/Branch_Failover_Page/tests/src/org/jboss/messaging/tests/integration/paging/PageCrashTest.java
Log:
small tweaks only

Modified: branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/paging/impl/PagingStoreImpl.java
===================================================================
--- branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/paging/impl/PagingStoreImpl.java	2009-01-13 17:11:41 UTC (rev 5621)
+++ branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/paging/impl/PagingStoreImpl.java	2009-01-13 17:32:39 UTC (rev 5622)
@@ -618,8 +618,6 @@
          currentPageLock.readLock().unlock();
       }
 
-      System.out.println("Paging " + this.getStoreName());
-
       // if the first check failed, we do it again under a global currentPageLock
       // (writeLock) this time
       writeLock.lock();

Modified: branches/Branch_Failover_Page/tests/src/org/jboss/messaging/tests/integration/paging/PageCrashTest.java
===================================================================
--- branches/Branch_Failover_Page/tests/src/org/jboss/messaging/tests/integration/paging/PageCrashTest.java	2009-01-13 17:11:41 UTC (rev 5621)
+++ branches/Branch_Failover_Page/tests/src/org/jboss/messaging/tests/integration/paging/PageCrashTest.java	2009-01-13 17:32:39 UTC (rev 5622)
@@ -115,10 +115,6 @@
       {
          ClientSessionFactory sf = createInVMFactory();
 
-         sf.setBlockOnNonPersistentSend(true);
-         sf.setBlockOnPersistentSend(true);
-         sf.setBlockOnAcknowledge(true);
-
          ClientSession session = sf.createSession(null, null, false, true, true, false, 0);
 
          session.start();
@@ -168,6 +164,8 @@
       {
          ClientSessionFactory sf = createInVMFactory();
 
+         // Making it synchronous, just because we want to stop sending messages as soon as the page-store becomes in page mode
+         // and we could only guarantee that by setting it to synchronous
          sf.setBlockOnNonPersistentSend(true);
          sf.setBlockOnPersistentSend(true);
          sf.setBlockOnAcknowledge(true);