[hornetq-commits] JBoss hornetq SVN: r8245 - trunk/tests/src/org/hornetq/tests/integration/cluster/failover.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-11-06 15:25:51 -0500 (Fri, 06 Nov 2009)
New Revision: 8245

Modified:
   trunk/tests/src/org/hornetq/tests/integration/cluster/failover/PagingFailoverTest.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-207 - removing invalid test

Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/failover/PagingFailoverTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/cluster/failover/PagingFailoverTest.java	2009-11-06 17:45:51 UTC (rev 8244)
+++ trunk/tests/src/org/hornetq/tests/integration/cluster/failover/PagingFailoverTest.java	2009-11-06 20:25:51 UTC (rev 8245)
@@ -58,28 +58,22 @@
    // Constructors --------------------------------------------------
 
    // Public --------------------------------------------------------
-
+   
    public void testPage() throws Exception
    {
-      internalTestPagedTransacted(false, false);
+      internalTestPage(false);
    }
    
-
-   public void testPageTransactioned() throws Exception
+   public void testPageFailBeforeconsume() throws Exception
    {
-      internalTestPagedTransacted(true, false);
+      internalTestPage(true);
    }
    
-   public void testPageTransactionedFailBeforeconsume() throws Exception
+   public void internalTestPage(final boolean failBeforeConsume) throws Exception
    {
-      internalTestPagedTransacted(true, true);
-   }
-   
-   public void internalTestPagedTransacted(final boolean transacted, final boolean failBeforeConsume) throws Exception
-   {
       ClientSessionFactoryInternal factory = getSessionFactory();
       factory.setBlockOnPersistentSend(true);
-      ClientSession session = factory.createSession(!transacted, !transacted, 0);
+      ClientSession session = factory.createSession(true, true, 0);
 
       try
       {
@@ -109,7 +103,7 @@
 
          for (int i = 0; i < TOTAL_MESSAGES; i++)
          {
-            if (transacted && i % 10 == 0)
+            if (i % 10 == 0)
             {
                session.commit();
             }
@@ -126,7 +120,6 @@
             failSession(session, latch);
          }
 
-
          session.start();
 
          ClientConsumer cons = session.createConsumer(ADDRESS);
@@ -138,7 +131,7 @@
             ClientMessage msg = cons.receive(20000);
             assertNotNull(msg);
             msg.acknowledge();
-            if (transacted && i % 10 == 0)
+            if (i % 10 == 0)
             {
                session.commit();
             }
@@ -252,5 +245,4 @@
    // Private -------------------------------------------------------
 
    // Inner classes -------------------------------------------------
-
 }