Author: clebert.suconic(a)jboss.com Date: 2010-12-17 17:03:22 -0500 (Fri, 17 Dec 2010) New Revision: 10056 Modified: trunk/tests/src/org/hornetq/tests/integration/paging/PagingCounterTest.java Log: fixing test Modified: trunk/tests/src/org/hornetq/tests/integration/paging/PagingCounterTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/paging/PagingCounterTest.java 2010-12-17 19:09:02 UTC (rev 10055) +++ trunk/tests/src/org/hornetq/tests/integration/paging/PagingCounterTest.java 2010-12-17 22:03:22 UTC (rev 10056) @@ -23,6 +23,7 @@ import org.hornetq.core.paging.cursor.PageSubscriptionCounter; import org.hornetq.core.paging.cursor.impl.PageSubscriptionCounterImpl; import org.hornetq.core.persistence.StorageManager; +import org.hornetq.core.persistence.impl.journal.OperationContextImpl; import org.hornetq.core.server.HornetQServer; import org.hornetq.core.server.Queue; import org.hornetq.core.settings.impl.AddressSettings; @@ -294,6 +295,8 @@ server.start(); + storage = server.getStorageManager(); + queue = server.locateQueue(new SimpleString("A1")); assertNotNull(queue); @@ -343,6 +346,9 @@ private HornetQServer newHornetQServer() { + + OperationContextImpl.clearContext(); + HornetQServer server = super.createServer(true, false); AddressSettings defaultSetting = new AddressSettings();