[hornetq-commits] JBoss hornetq SVN: r9935 - branches/2_2_0_HA_Improvements_preMerge/tests/src/org/hornetq/tests/integration/cluster/failover.
do-not-reply at jboss.org
do-not-reply at jboss.org
Sat Nov 27 07:09:17 EST 2010
Author: ataylor
Date: 2010-11-27 07:09:17 -0500 (Sat, 27 Nov 2010)
New Revision: 9935
Modified:
branches/2_2_0_HA_Improvements_preMerge/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTest.java
Log:
fixed test
Modified: branches/2_2_0_HA_Improvements_preMerge/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTest.java
===================================================================
--- branches/2_2_0_HA_Improvements_preMerge/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTest.java 2010-11-26 14:58:09 UTC (rev 9934)
+++ branches/2_2_0_HA_Improvements_preMerge/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTest.java 2010-11-27 12:09:17 UTC (rev 9935)
@@ -105,6 +105,7 @@
{
locator.setBlockOnNonDurableSend(true);
locator.setBlockOnDurableSend(true);
+ locator.setAckBatchSize(0);
locator.setReconnectAttempts(-1);
ClientSessionFactoryInternal sf = (ClientSessionFactoryInternal)locator.createSessionFactory();
@@ -157,7 +158,7 @@
crash(session);
int retry = 0;
- while (received.size() != numMessages)
+ while (received.size() >= numMessages)
{
Thread.sleep(1000);
retry++;
@@ -166,8 +167,10 @@
break;
}
}
+ System.out.println("received.size() = " + received.size());
+ session.close();
- session.close();
+ sf.close();
Assert.assertTrue(retry <= 5);
More information about the hornetq-commits
mailing list