Author: kfujino
Date: Mon Dec 21 04:50:32 2015
New Revision: 1721086
URL: http://svn.apache.org/viewvc?rev=1721086&view=rev
Log:
Ensure that the shutdown command of member is cleared.
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/StaticMembershipInterceptor.java
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/StaticMembershipInterceptor.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/StaticMembershipInterceptor.java?rev=1721086&r1=1721085&r2=1721086&view=diff
==============================================================================
---
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/StaticMembershipInterceptor.java
(original)
+++
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/StaticMembershipInterceptor.java
Mon Dec 21 04:50:32 2015
@@ -83,8 +83,12 @@ public class StaticMembershipInterceptor
// receive member shutdown
Member member = getMember(msg.getAddress());
if (member != null) {
- member.setCommand(Member.SHUTDOWN_PAYLOAD);
- super.memberDisappeared(member);
+ try {
+ member.setCommand(Member.SHUTDOWN_PAYLOAD);
+ super.memberDisappeared(member);
+ } finally {
+ member.setCommand(new byte[0]);
+ }
}
} else {
super.messageReceived(msg);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
