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);