svn commit: r935466 - in /openejb/trunk/openejb3/server/openejb-multicast/src/main/java/org/apache/openejb/server/discovery: MultipointServer.java Tracker.java

[dblevins]

Author: dblevins
Date: Mon Apr 19 07:02:22 2010
New Revision: 935466

URL: http://svn.apache.org/viewvc?rev=935466&view=rev
Log:
Yanked stdout printing. Returned heartbeat to 500 ms

Modified:
    
openejb/trunk/openejb3/server/openejb-multicast/src/main/java/org/apache/openejb/server/discovery/MultipointServer.java
    
openejb/trunk/openejb3/server/openejb-multicast/src/main/java/org/apache/openejb/server/discovery/Tracker.java

Modified: 
openejb/trunk/openejb3/server/openejb-multicast/src/main/java/org/apache/openejb/server/discovery/MultipointServer.java
URL: 
http://svn.apache.org/viewvc/openejb/trunk/openejb3/server/openejb-multicast/src/main/java/org/apache/openejb/server/discovery/MultipointServer.java?rev=935466&r1=935465&r2=935466&view=diff
==============================================================================
--- 
openejb/trunk/openejb3/server/openejb-multicast/src/main/java/org/apache/openejb/server/discovery/MultipointServer.java
 (original)
+++ 
openejb/trunk/openejb3/server/openejb-multicast/src/main/java/org/apache/openejb/server/discovery/MultipointServer.java
 Mon Apr 19 07:02:22 2010
@@ -134,7 +134,7 @@ public class MultipointServer {
         }
 
         private void trace(String str) {
-            println(message(str));
+//            println(message(str));
 
             if (log.isDebugEnabled()) {
                 log.debug(message(str));
@@ -649,15 +649,9 @@ public class MultipointServer {
         }
     }
 
-    private int rank(Session session) {
-        Socket socket = session.channel.socket();
-        
-        return socket.getLocalPort() + socket.getPort();
-    }
-
     private void println(String s) {
-        if (s.matches(".*(Listening|DONE|KEEP|KILL)")) {
-            System.out.format("%1$tH:%1$tM:%1$tS.%1$tL - %2$s\n", 
System.currentTimeMillis(), s);
-        }
+//        if (s.matches(".*(Listening|DONE|KEEP|KILL)")) {
+//            System.out.format("%1$tH:%1$tM:%1$tS.%1$tL - %2$s\n", 
System.currentTimeMillis(), s);
+//        }
     }
 }

Modified: 
openejb/trunk/openejb3/server/openejb-multicast/src/main/java/org/apache/openejb/server/discovery/Tracker.java
URL: 
http://svn.apache.org/viewvc/openejb/trunk/openejb3/server/openejb-multicast/src/main/java/org/apache/openejb/server/discovery/Tracker.java?rev=935466&r1=935465&r2=935466&view=diff
==============================================================================
--- 
openejb/trunk/openejb3/server/openejb-multicast/src/main/java/org/apache/openejb/server/discovery/Tracker.java
 (original)
+++ 
openejb/trunk/openejb3/server/openejb-multicast/src/main/java/org/apache/openejb/server/discovery/Tracker.java
 Mon Apr 19 07:02:22 2010
@@ -311,7 +311,7 @@ public class Tracker {
     public static class Builder {
         private String group = "default";
         private int maxMissedHeartbeats = 10;
-        private long heartRate = 5000;
+        private long heartRate = 500;
         // ---------------------------------
         // Listenting specific settings
         private long reconnectDelay = 1000 * 5;