[hornetq-commits] JBoss hornetq SVN: r9934 - 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
Fri Nov 26 09:58:10 EST 2010
Author: ataylor
Date: 2010-11-26 09:58:09 -0500 (Fri, 26 Nov 2010)
New Revision: 9934
Modified:
branches/2_2_0_HA_Improvements_preMerge/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTest.java
Log:
set reconnect attempts on 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 12:41:48 UTC (rev 9933)
+++ 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)
@@ -105,6 +105,7 @@
{
locator.setBlockOnNonDurableSend(true);
locator.setBlockOnDurableSend(true);
+ locator.setReconnectAttempts(-1);
ClientSessionFactoryInternal sf = (ClientSessionFactoryInternal)locator.createSessionFactory();
@@ -112,18 +113,7 @@
session.createQueue(FailoverTestBase.ADDRESS, FailoverTestBase.ADDRESS, null, true);
- final CountDownLatch latch = new CountDownLatch(1);
- class MyListener extends BaseListener
- {
- public void connectionFailed(final HornetQException me, final boolean failover)
- {
- latch.countDown();
- }
- }
-
- session.addFailureListener(new MyListener());
-
ClientProducer producer = session.createProducer(FailoverTestBase.ADDRESS);
final int numMessages = 100;
More information about the hornetq-commits
mailing list