You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by az...@apache.org on 2008/10/08 12:13:35 UTC
svn commit: r702793 -
/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/Axis2Coordinator.java
Author: azeez
Date: Wed Oct 8 03:13:34 2008
New Revision: 702793
URL: http://svn.apache.org/viewvc?rev=702793&view=rev
Log:
Handle only membership changes related to the same domain
Modified:
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/Axis2Coordinator.java
Modified: webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/Axis2Coordinator.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/Axis2Coordinator.java?rev=702793&r1=702792&r2=702793&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/Axis2Coordinator.java (original)
+++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/Axis2Coordinator.java Wed Oct 8 03:13:34 2008
@@ -32,20 +32,24 @@
public void memberAdded(Member member) {
super.memberAdded(member);
- if (membershipListener != null) {
+ if (membershipListener != null &&
+ TribesUtil.areInSameDomain(getLocalMember(true), member)) {
membershipListener.memberAdded(TribesUtil.toAxis2Member(member), isCoordinator());
}
}
public void memberDisappeared(Member member) {
super.memberDisappeared(member);
+ if(!TribesUtil.areInSameDomain(getLocalMember(true), member)){
+ return;
+ }
if (isCoordinator()) {
if (TribesUtil.toAxis2Member(member).isActive()) {
// If the local member is PASSIVE, we try to activate it
if (!TribesUtil.toAxis2Member(getLocalMember(true)).isActive()) {
//TODO: ACTIVATE local member
-
+
} else {
Member[] members = getMembers();
for (Member aMember : members) {