[jboss-cvs] JBoss Messaging SVN: r5344 - trunk/tests/src/org/jboss/messaging/tests/integration/xa.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2008-11-12 13:22:15 -0500 (Wed, 12 Nov 2008)
New Revision: 5344

Modified:
   trunk/tests/src/org/jboss/messaging/tests/integration/xa/BasicXaRecoveryTest.java
Log:
https://jira.jboss.org/jira/browse/JBMESSAGING-1449

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/xa/BasicXaRecoveryTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/xa/BasicXaRecoveryTest.java	2008-11-12 17:03:05 UTC (rev 5343)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/xa/BasicXaRecoveryTest.java	2008-11-12 18:22:15 UTC (rev 5344)
@@ -237,17 +237,16 @@
       testMultipleTxReceiveWithRollback(true);  
    }
    
-// https://jira.jboss.org/jira/browse/JBMESSAGING-1449   
-//   public void testPagingServerRestarted() throws Exception
-//   {
-//      testPaging(true);
-//   }
-//   
-//   public void testPaging() throws Exception
-//   {
-//      testPaging(false);
-//   }
+   public void testPagingServerRestarted() throws Exception
+   {
+      testPaging(true);
+   }
    
+   public void testPaging() throws Exception
+   {
+      testPaging(false);
+   }
+   
    public void testPaging(boolean restartServer) throws Exception
    {
       Xid xid = new XidImpl("xa1".getBytes(), 1, new GUID().toString().getBytes());
@@ -296,8 +295,12 @@
 
       clientSession.commit(xid, true);
 
+      clientSession.close();
+      
+      clientSession = sessionFactory.createSession(false, false, false);
+
       clientSession.start();
-
+      
       ClientConsumer pageConsumer = clientSession.createConsumer(pageQueue);
 
       for (int i = 0; i < 1000; i++)
@@ -305,6 +308,7 @@
          ClientMessage m = pageConsumer.receive(10000);
          assertNotNull(m);
          m.acknowledge();
+         clientSession.commit();
       }  
       
    }