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 2007/04/07 08:48:45 UTC

svn commit: r526382 - in /webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes: ChannelListener.java TribesMembershipListener.java

Author: azeez
Date: Fri Apr  6 23:48:44 2007
New Revision: 526382

URL: http://svn.apache.org/viewvc?view=rev&rev=526382
Log:
Improving the displayed message
Set the event type in the event



Modified:
    webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/ChannelListener.java
    webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/TribesMembershipListener.java

Modified: webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/ChannelListener.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/ChannelListener.java?view=diff&rev=526382&r1=526381&r2=526382
==============================================================================
--- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/ChannelListener.java (original)
+++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/ChannelListener.java Fri Apr  6 23:48:44 2007
@@ -161,6 +161,7 @@
             ConfigurationCommand command = (ConfigurationCommand) msg;
             ConfigurationEvent event = new ConfigurationEvent();
             int commandType = command.getCommandType();
+            event.setConfigurationType(command.getCommandType());
             switch (commandType) {
                 case CommandType.LOAD_SERVICE_GROUPS:
                     event.setServiceGroupNames(command.getServiceGroupNames());

Modified: webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/TribesMembershipListener.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/TribesMembershipListener.java?view=diff&rev=526382&r1=526381&r2=526382
==============================================================================
--- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/TribesMembershipListener.java (original)
+++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/TribesMembershipListener.java Fri Apr  6 23:48:44 2007
@@ -28,20 +28,19 @@
     private static Log log = LogFactory.getLog(TribesMembershipListener.class);
 
     public void memberAdded(Member member) {
-        log.info("New member " + getHostIP(member) + ":" + member.getPort() +
-                 " added to Tribes group.");
+        log.info("New member " + getHostSocket(member) + " added to Tribes group.");
     }
 
     public void memberDisappeared(Member member) {
-        log.info("Member " + getHostIP(member) + " left Tribes group");
+        log.info("Member " + getHostSocket(member) + " left Tribes group");
     }
 
-    private String getHostIP(Member member) {
-        String host = "";
+    private String getHostSocket(Member member) {
+        String host = null;
         byte[] hostBytes = member.getHost();
         for (int i = 0; i < hostBytes.length; i++) {
-            host += hostBytes[i] + ".";
+            host = (host == null) ? ("" + hostBytes[i]) : (host + "." + hostBytes[i]);
         }
-        return host;
+        return host + ":" + member.getPort();
     }
 }



---------------------------------------------------------------------
To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org