[hornetq-commits] JBoss hornetq SVN: r10101 - trunk/src/main/org/hornetq/core/paging/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-01-01 19:57:33 -0500 (Sat, 01 Jan 2011)
New Revision: 10101

Modified:
   trunk/src/main/org/hornetq/core/paging/impl/PagingStoreImpl.java
Log:
fixing test

Modified: trunk/src/main/org/hornetq/core/paging/impl/PagingStoreImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/paging/impl/PagingStoreImpl.java	2011-01-02 00:48:23 UTC (rev 10100)
+++ trunk/src/main/org/hornetq/core/paging/impl/PagingStoreImpl.java	2011-01-02 00:57:33 UTC (rev 10101)
@@ -16,7 +16,6 @@
 import java.text.DecimalFormat;
 import java.util.Collections;
 import java.util.HashSet;
-import java.util.LinkedList;
 import java.util.List;
 import java.util.Queue;
 import java.util.Set;
@@ -56,9 +55,8 @@
 import org.hornetq.core.settings.impl.AddressSettings;
 import org.hornetq.core.transaction.Transaction;
 import org.hornetq.core.transaction.Transaction.State;
-import org.hornetq.core.transaction.TransactionOperationAbstract;
-import org.hornetq.core.transaction.impl.TransactionImpl;
 import org.hornetq.core.transaction.TransactionOperation;
+import org.hornetq.core.transaction.TransactionOperationAbstract;
 import org.hornetq.core.transaction.TransactionPropertyIndexes;
 import org.hornetq.utils.ExecutorFactory;
 import org.hornetq.utils.Future;
@@ -877,6 +875,7 @@
          {
             // Make sure nothing is currently validating or using currentPage
             openNewPage();
+            currentPageSize.addAndGet(bytesToWrite);
          }
 
          currentPage.write(pagedMessage);