Author: kfujino
Date: Tue Jun 18 07:09:57 2013
New Revision: 1494043

URL: http://svn.apache.org/r1494043
Log:
Add logging of when a member is unable to join the cluster.
Modified:
    
tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java
    tomcat/tc7.0.x/trunk/webapps/docs/changelog.xml

Modified: 
tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java
URL: 
http://svn.apache.org/viewvc/tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java?rev=1494043&r1=1494042&r2=1494043&view=diff
==============================================================================
--- 
tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java
 (original)
+++ 
tomcat/tc7.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java
 Tue Jun 18 07:09:57 2013
@@ -23,6 +23,8 @@ import org.apache.catalina.tribes.Member
 import org.apache.catalina.tribes.group.ChannelInterceptorBase;
 import org.apache.catalina.tribes.membership.MemberImpl;
 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>
@@ -34,7 +36,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];
@@ -54,7 +56,11 @@ public class DomainFilterInterceptor ext
             notify = Arrays.equals(domain,member.getDomain());
             if ( notify ) notify = membership.memberAlive((MemberImpl)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

Modified: tomcat/tc7.0.x/trunk/webapps/docs/changelog.xml
URL: 
http://svn.apache.org/viewvc/tomcat/tc7.0.x/trunk/webapps/docs/changelog.xml?rev=1494043&r1=1494042&r2=1494043&view=diff
==============================================================================
--- tomcat/tc7.0.x/trunk/webapps/docs/changelog.xml (original)
+++ tomcat/tc7.0.x/trunk/webapps/docs/changelog.xml Tue Jun 18 07:09:57 2013
@@ -82,6 +82,9 @@
         <code>keepAliveCount</code>/<code>keepAliveTime</code> is set to a 
value
         greater than 0. (kfujino)
       </fix>
+      <add>
+        Add logging of when a member is unable to join the cluster. (kfujino)
+      </add>
     </changelog>
   </subsection>
   <subsection name="Other">



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

Reply via email to