[hornetq-commits] JBoss hornetq SVN: r10056 - trunk/tests/src/org/hornetq/tests/integration/paging.

[do-not-reply at jboss.org]

Author: clebert.suconic at 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();