You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by kf...@apache.org on 2013/06/18 09:06:06 UTC
svn commit: r1494042 -
/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java
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-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org