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/12/08 14:21:30 UTC
svn commit: r724335 -
/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java
Author: azeez
Date: Mon Dec 8 05:21:29 2008
New Revision: 724335
URL: http://svn.apache.org/viewvc?rev=724335&view=rev
Log:
Set custom member properties
Modified:
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java
Modified: webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java?rev=724335&r1=724334&r2=724335&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java (original)
+++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java Mon Dec 8 05:21:29 2008
@@ -233,6 +233,23 @@
memberInfo.setProperty(ClusteringConstants.Parameters.IS_ACTIVE,
(String) isActiveParam.getValue());
}
+
+ Parameter propsParam = getParameter("properties");
+ if(propsParam != null){
+ OMElement paramEle = propsParam.getParameterElement();
+ for(Iterator iter = paramEle.getChildrenWithLocalName("property"); iter.hasNext();){
+ OMElement propEle = (OMElement) iter.next();
+ OMAttribute nameAttrib = propEle.getAttribute(new QName("name"));
+ if(nameAttrib != null){
+ OMAttribute valueAttrib = propEle.getAttribute(new QName("value"));
+ if (valueAttrib != null) {
+ memberInfo.setProperty(nameAttrib.getAttributeValue(),
+ valueAttrib.getAttributeValue());
+ }
+ }
+ }
+ }
+
ByteArrayOutputStream bout = new ByteArrayOutputStream();
try {
memberInfo.store(bout, "");
@@ -370,7 +387,7 @@
private void configureMembershipScheme(byte[] localDomain,
List<MembershipManager> membershipManagers)
throws ClusteringFault {
- MembershipListener membershipListener = null;
+ MembershipListener membershipListener;
Parameter parameter = getParameter(ClusteringConstants.Parameters.MEMBERSHIP_LISTENER);
if (parameter != null) {
OMElement paramEle = parameter.getParameterElement();