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 pr...@apache.org on 2007/06/17 14:11:57 UTC
svn commit: r548033 [4/11] - in /webservices/axis2/branches/java/jaxws21: ./
etc/ modules/adb-codegen/ modules/adb-codegen/src/org/apache/axis2/schema/
modules/adb-codegen/src/org/apache/axis2/schema/template/
modules/adb-codegen/src/org/apache/axis2/s...
Modified: webservices/axis2/branches/java/jaxws21/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesMembershipListener.java
URL: http://svn.apache.org/viewvc/webservices/axis2/branches/java/jaxws21/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesMembershipListener.java?view=diff&rev=548033&r1=548032&r2=548033
==============================================================================
--- webservices/axis2/branches/java/jaxws21/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesMembershipListener.java (original)
+++ webservices/axis2/branches/java/jaxws21/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesMembershipListener.java Sun Jun 17 05:11:16 2007
@@ -28,12 +28,12 @@
private static Log log = LogFactory.getLog(TribesMembershipListener.class);
public void memberAdded(Member member) {
- log.info("New member " + member.getName() + " joined cluster.");
+ log.info("New member " + TribesUtil.getHost(member) + " joined cluster.");
// System.err.println("++++++ IS COORD="+TribesClusterManager.nbc.isCoordinator());
}
public void memberDisappeared(Member member) {
- log.info("Member " + member.getName() + " left cluster");
+ log.info("Member " + TribesUtil.getHost(member) + " left cluster");
// System.err.println("++++++ IS COORD="+TribesClusterManager.nbc.isCoordinator());
}
}
Modified: webservices/axis2/branches/java/jaxws21/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesUtil.java
URL: http://svn.apache.org/viewvc/webservices/axis2/branches/java/jaxws21/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesUtil.java?view=diff&rev=548033&r1=548032&r2=548033
==============================================================================
--- webservices/axis2/branches/java/jaxws21/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesUtil.java (original)
+++ webservices/axis2/branches/java/jaxws21/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesUtil.java Sun Jun 17 05:11:16 2007
@@ -16,6 +16,7 @@
package org.apache.axis2.clustering.tribes;
+import org.apache.catalina.tribes.Channel;
import org.apache.catalina.tribes.Member;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -25,21 +26,12 @@
private static Log log = LogFactory.getLog(TribesUtil.class);
public static void printMembers(Member[] members) {
-
-
if (members != null) {
int length = members.length;
if (length > 0) {
log.info("Members of current cluster");
for (int i = 0; i < length; i++) {
- byte[] hostBts = members[i].getHost();
- String host = null;
- if (hostBts != null) {
- for (int j = 0; j < hostBts.length; j++) {
- host = host == null ? ("" + hostBts[j]) : (host + "." + hostBts[j]);
- }
- }
- log.info("Member" + (i + 1) + " " + members[i].getName());
+ log.info("Member" + (i + 1) + " " + getHost(members[i]));
}
} else {
log.info("No members in current cluster");
@@ -47,4 +39,19 @@
}
}
+ public static String getHost(Member member) {
+ byte[] hostBytes = member.getHost();
+ StringBuffer host = new StringBuffer();
+ if (hostBytes != null) {
+ for (int i = 0; i < hostBytes.length; i++) {
+ int hostByte = hostBytes[i] >= 0 ? (int) hostBytes[i] : (int) hostBytes[i] + 256;
+ host.append(hostByte).append(".");
+ }
+ }
+ return host.append(":").append(member.getPort()).toString();
+ }
+
+ public static String getLocalHost(Channel channel) {
+ return getHost(channel.getLocalMember(true));
+ }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org