Author: clebert.suconic(a)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 ------------------------------------------------- - }