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 2018/08/06 09:21:37 UTC
svn commit: r1837497 -
/tomcat/trunk/java/org/apache/catalina/tribes/membership/StaticMembershipProvider.java
Author: kfujino
Date: Mon Aug 6 09:21:37 2018
New Revision: 1837497
URL: http://svn.apache.org/viewvc?rev=1837497&view=rev
Log:
Add SHUTDOWN_PAYLOAD on local member when stopping membership.
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/membership/StaticMembershipProvider.java
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=1837497&r1=1837496&r2=1837497&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/membership/StaticMembershipProvider.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/membership/StaticMembershipProvider.java Mon Aug 6 09:21:37 2018
@@ -201,7 +201,9 @@ public class StaticMembershipProvider ex
protected void stopMembership(Member[] members) {
if (members.length == 0 ) return;
- MemberMessage msg = new MemberMessage(membershipId, MemberMessage.MSG_STOP, service.getLocalMember(true));
+ Member localmember = service.getLocalMember(false);
+ localmember.setCommand(Member.SHUTDOWN_PAYLOAD);
+ MemberMessage msg = new MemberMessage(membershipId, MemberMessage.MSG_STOP, localmember);
try {
channel.send(members, msg, sendOptions);
} catch (ChannelException e) {
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org