[hornetq-commits] JBoss hornetq SVN: r12256 - in trunk: tests/integration-tests/src/test/java/org/hornetq/tests/util and 1 other directory.

[do-not-reply at jboss.org]

Author: borges
Date: 2012-03-07 07:48:48 -0500 (Wed, 07 Mar 2012)
New Revision: 12256

Modified:
   trunk/hornetq-core/src/main/java/org/hornetq/core/config/ClusterConnectionConfiguration.java
   trunk/tests/integration-tests/src/test/java/org/hornetq/tests/util/ReplicatedBackupUtils.java
Log:
HORNETQ-720 Set positive value for the cluster retry interval of replication tests

Modified: trunk/hornetq-core/src/main/java/org/hornetq/core/config/ClusterConnectionConfiguration.java
===================================================================
--- trunk/hornetq-core/src/main/java/org/hornetq/core/config/ClusterConnectionConfiguration.java	2012-03-07 12:48:23 UTC (rev 12255)
+++ trunk/hornetq-core/src/main/java/org/hornetq/core/config/ClusterConnectionConfiguration.java	2012-03-07 12:48:48 UTC (rev 12256)
@@ -122,6 +122,8 @@
       this.connectorName = connectorName;
       this.clientFailureCheckPeriod = clientFailureCheckPeriod;
       this.connectionTTL = connectionTTL;
+      if (retryInterval <= 0)
+         throw new IllegalArgumentException("retry interval must be positive, was " + retryInterval);
       this.retryInterval = retryInterval;
       this.retryIntervalMultiplier = retryIntervalMultiplier;
       this.maxRetryInterval = maxRetryInterval;

Modified: trunk/tests/integration-tests/src/test/java/org/hornetq/tests/util/ReplicatedBackupUtils.java
===================================================================
--- trunk/tests/integration-tests/src/test/java/org/hornetq/tests/util/ReplicatedBackupUtils.java	2012-03-07 12:48:23 UTC (rev 12255)
+++ trunk/tests/integration-tests/src/test/java/org/hornetq/tests/util/ReplicatedBackupUtils.java	2012-03-07 12:48:48 UTC (rev 12256)
@@ -33,7 +33,7 @@
          conn.add(iConn);
       }
       ClusterConnectionConfiguration clusterConfig =
-               new ClusterConnectionConfiguration("cluster1", "jms", name, -1, false, false, 1, 1, conn, false);
+               new ClusterConnectionConfiguration("cluster1", "jms", name, 250, false, false, 1, 1, conn, false);
       configuration.getClusterConfigurations().add(clusterConfig);
    }