Author: kfujino
Date: Mon Dec 21 05:04:08 2015
New Revision: 1721087
URL: http://svn.apache.org/viewvc?rev=1721087&view=rev
Log:
Refactoring.
Remove duplicated codes.
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=1721087&r1=1721086&r2=1721087&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 05:04:08 2015
@@ -199,28 +199,16 @@ public class StaticMembershipInterceptor
}
protected void sendLocalMember(Member[] members) {
- if ( members == null || members.length == 0 ) return;
- ChannelData data = new ChannelData(true);
- data.setAddress(getLocalMember(false));
- data.setTimestamp(System.currentTimeMillis());
- data.setOptions(getOptionFlag());
- data.setMessage(new XByteBuffer(MEMBER_START, false));
try {
- super.sendMessage(members, data, null);
+ sendMemberMessage(members, MEMBER_START);
} catch (ChannelException cx) {
log.warn(sm.getString("staticMembershipInterceptor.sendLocalMember.failed"),cx);
}
}
protected void sendShutdown(Member[] members) {
- if ( members == null || members.length == 0 ) return;
- ChannelData data = new ChannelData(true);
- data.setAddress(getLocalMember(false));
- data.setTimestamp(System.currentTimeMillis());
- data.setOptions(getOptionFlag());
- data.setMessage(new XByteBuffer(MEMBER_STOP, false));
try {
- super.sendMessage(members, data, null);
+ sendMemberMessage(members, MEMBER_STOP);
} catch (ChannelException cx) {
log.warn(sm.getString("staticMembershipInterceptor.sendShutdown.failed"),cx);
}
@@ -235,4 +223,14 @@ public class StaticMembershipInterceptor
} while (now.getPrevious() != null);
return result;
}
+
+ protected void sendMemberMessage(Member[] members, byte[] message) throws
ChannelException {
+ if ( members == null || members.length == 0 ) return;
+ ChannelData data = new ChannelData(true);
+ data.setAddress(getLocalMember(false));
+ data.setTimestamp(System.currentTimeMillis());
+ data.setOptions(getOptionFlag());
+ data.setMessage(new XByteBuffer(message, false));
+ super.sendMessage(members, data, null);
+ }
}
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscr...@tomcat.apache.org
For additional commands, e-mail: dev-h...@tomcat.apache.org
