[hornetq-commits] JBoss hornetq SVN: r10101 - trunk/src/main/org/hornetq/core/paging/impl.
Author: clebert.suconic(a)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);