Author: kfujino Date: Mon Jul 30 09:21:41 2018 New Revision: 1837033 URL: http://svn.apache.org/viewvc?rev=1837033&view=rev Log: Implement MemberMessage.getTypeDesc(). Add log messagess.
Modified: tomcat/trunk/java/org/apache/catalina/tribes/membership/LocalStrings.properties tomcat/trunk/java/org/apache/catalina/tribes/membership/StaticMembershipProvider.java Modified: tomcat/trunk/java/org/apache/catalina/tribes/membership/LocalStrings.properties URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/membership/LocalStrings.properties?rev=1837033&r1=1837032&r2=1837033&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/catalina/tribes/membership/LocalStrings.properties (original) +++ tomcat/trunk/java/org/apache/catalina/tribes/membership/LocalStrings.properties Mon Jul 30 09:21:41 2018 @@ -51,4 +51,6 @@ memberImpl.unableParse.hostname=Unable t memberImpl.large.payload=Payload is to large for tribes to handle. staticMember.invalid.uuidLength=UUID must be exactly 16 bytes, not:[{0}] staticMembershipService.stopFail=Unable to stop the static membership service, level: [{0}] -staticMembershipProvider.pingThread.failed=Unable to send ping. \ No newline at end of file +staticMembershipProvider.pingThread.failed=Unable to send ping. +staticMembershipProvider.replyRequest.ignored=Message[{0}] is ignored. +staticMembershipProvider.leftOver.ignored=Message[{0}] is ignored. \ No newline at end of file Modified: tomcat/trunk/java/org/apache/catalina/tribes/membership/StaticMembershipProvider.java URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/membership/StaticMembershipProvider.java?rev=1837033&r1=1837032&r2=1837033&view=diff ============================================================================== --- tomcat/trunk/java/org/apache/catalina/tribes/membership/StaticMembershipProvider.java (original) +++ tomcat/trunk/java/org/apache/catalina/tribes/membership/StaticMembershipProvider.java Mon Jul 30 09:21:41 2018 @@ -219,7 +219,8 @@ public class StaticMembershipProvider ex } else { // other messages are ignored. if (log.isInfoEnabled()) - log.info("never happen"); + log.info(sm.getString("staticMembershipProvider.replyRequest.ignored", + memMsg.getTypeDesc())); return null; } } @@ -235,7 +236,8 @@ public class StaticMembershipProvider ex } else { // other messages are ignored. if (log.isInfoEnabled()) - log.info("never happen"); + log.info(sm.getString("staticMembershipProvider.leftOver.ignored", + memMsg.getTypeDesc())); } } @@ -342,6 +344,19 @@ public class StaticMembershipProvider ex public String toString() { return super.toString(); } + + protected String getTypeDesc() { + switch (msgtype) { + case MSG_START: + return "MSG_START"; + case MSG_STOP: + return "MSG_STOP"; + case MSG_PING: + return "MSG_PING"; + default: + return "UNKNOWN"; + } + } } protected class PingThread extends Thread { --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org For additional commands, e-mail: dev-h...@tomcat.apache.org