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

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); }