svn commit: r1240881 - /openejb/trunk/openejb/server/openejb-multicast/src/test/java/org/apache/openejb/server/discovery/MultipointDiscoveryAgentTest.java

[ad...@apache.org]

Author: adc
Date: Mon Feb  6 02:37:22 2012
New Revision: 1240881

URL: http://svn.apache.org/viewvc?rev=1240881&view=rev
Log:
OPENEJB-1766 MultipointDiscoveryAgentTest needs to allow more missed heartbeats

Modified:
    openejb/trunk/openejb/server/openejb-multicast/src/test/java/org/apache/openejb/server/discovery/MultipointDiscoveryAgentTest.java

Modified: openejb/trunk/openejb/server/openejb-multicast/src/test/java/org/apache/openejb/server/discovery/MultipointDiscoveryAgentTest.java
URL: http://svn.apache.org/viewvc/openejb/trunk/openejb/server/openejb-multicast/src/test/java/org/apache/openejb/server/discovery/MultipointDiscoveryAgentTest.java?rev=1240881&r1=1240880&r2=1240881&view=diff
==============================================================================
--- openejb/trunk/openejb/server/openejb-multicast/src/test/java/org/apache/openejb/server/discovery/MultipointDiscoveryAgentTest.java (original)
+++ openejb/trunk/openejb/server/openejb-multicast/src/test/java/org/apache/openejb/server/discovery/MultipointDiscoveryAgentTest.java Mon Feb  6 02:37:22 2012
@@ -105,7 +105,7 @@ public class MultipointDiscoveryAgentTes
         System.setProperty("log4j.appender.C.layout.ConversionPattern", "%d - %m%n");
 
         final URI greenService = new URI("green://localhost:5555");
-        final Node green = new Node(5555, new Listener("green"), true, "green", 5000);
+        final Node green = new Node(5555, new Listener("green"), true, "green", 100, 2);
 
         green.getRegistry().registerService(greenService);
 
@@ -135,10 +135,10 @@ public class MultipointDiscoveryAgentTes
         private final DiscoveryRegistry registry;
 
         public Node(int p, DiscoveryListener listener, int... peers) throws Exception {
-            this(p, listener, false, null, 5000, peers);
+            this(p, listener, false, null, 100, 2, peers);
         }
 
-        public Node(int p, DiscoveryListener listener, boolean debug, String name, int heartRate, int... peers) throws Exception {
+        public Node(int p, DiscoveryListener listener, boolean debug, String name, int heartRate, int maxMissHeartBeats, int... peers) throws Exception {
             this.agent = new MultipointDiscoveryAgent(debug, name);
             final Properties props = new Properties();
             props.put("port", p+"");
@@ -150,7 +150,8 @@ public class MultipointDiscoveryAgentTes
 
             props.put("initialServers", Join.join(",", uris));
             props.put("max_missed_heartbeats", "1");
-            props.put("heart_rate", ""+ heartRate);
+            props.put("heart_rate", "" + heartRate);
+            props.put("max_missed_heartbeats", "" + maxMissHeartBeats);
             agent.init(props);
 
             this.registry = new DiscoveryRegistry(agent);