[Dev] Patch for adding members to (wka) ELBs if the cluster members were started before the ELBs

[Afkham Azeez]

Index:
src/main/java/org/wso2/carbon/core/clustering/hazelcast/wka/WKABasedMembershipScheme.java
===================================================================
---
src/main/java/org/wso2/carbon/core/clustering/hazelcast/wka/WKABasedMembershipScheme.java
(revision
183858)
+++
src/main/java/org/wso2/carbon/core/clustering/hazelcast/wka/WKABasedMembershipScheme.java
(working
copy)
@@ -139,7 +139,14 @@
             if
(primaryHazelcastInstance.getCluster().getLocalMember().equals(member)) {
                 return;
             }
+            IMap<String, Member> membersMap =
MemberUtils.getMembersMap(primaryHazelcastInstance, primaryDomain);
+            org.apache.axis2.clustering.Member carbonLocalMember =
+                    MemberUtils.getLocalMember(primaryDomain,
+
localMember.getInetSocketAddress().getAddress().getHostAddress(),
+
localMember.getInetSocketAddress().getPort());
+            membersMap.put(localMember.getUuid(), carbonLocalMember);
             carbonCluster.memberAdded(member);
+
             HazelcastUtil.sendMessagesToMember(messageBuffer, member,
carbonCluster);
             log.info("Member joined [" + member.getUuid() + "]: " +
                      member.getInetSocketAddress().toString());

_______________________________________________
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev