svn commit: r1494042 - /tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java

[kfujino]

Author: kfujino
Date: Tue Jun 18 07:06:06 2013
New Revision: 1494042

URL: http://svn.apache.org/r1494042
Log:
Add logging of when a member is unable to join the cluster.

Modified:
    
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java

Modified: 
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java
URL: 
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java?rev=1494042&r1=1494041&r2=1494042&view=diff
==============================================================================
--- 
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java
 (original)
+++ 
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java
 Tue Jun 18 07:06:06 2013
@@ -22,6 +22,8 @@ import org.apache.catalina.tribes.Channe
 import org.apache.catalina.tribes.Member;
 import org.apache.catalina.tribes.group.ChannelInterceptorBase;
 import org.apache.catalina.tribes.membership.Membership;
+import org.apache.juli.logging.Log;
+import org.apache.juli.logging.LogFactory;
 
 /**
  * <p>Title: Member domain filter interceptor </p>
@@ -33,7 +35,7 @@ import org.apache.catalina.tribes.member
  * @version 1.0
  */
 public class DomainFilterInterceptor extends ChannelInterceptorBase {
-
+    private static final Log log = 
LogFactory.getLog(DomainFilterInterceptor.class);
     protected Membership membership = null;
 
     protected byte[] domain = new byte[0];
@@ -53,7 +55,11 @@ public class DomainFilterInterceptor ext
             notify = Arrays.equals(domain,member.getDomain());
             if ( notify ) notify = membership.memberAlive(member);
         }
-        if ( notify ) super.memberAdded(member);
+        if ( notify ) {
+            super.memberAdded(member);
+        } else {
+            if(log.isInfoEnabled()) log.info("Member was refused to join 
cluster["+member+"]");
+        }
     }
 
     @Override



---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org