axis-java-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From az...@apache.org
Subject svn commit: r673357 - /webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/LoadBalancerMode.java
Date Wed, 02 Jul 2008 11:07:25 GMT
Author: azeez
Date: Wed Jul  2 04:07:24 2008
New Revision: 673357

URL: http://svn.apache.org/viewvc?rev=673357&view=rev
Log:
Cleanup

Modified:
    webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/LoadBalancerMode.java

Modified: webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/LoadBalancerMode.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/LoadBalancerMode.java?rev=673357&r1=673356&r2=673357&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/LoadBalancerMode.java
(original)
+++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/LoadBalancerMode.java
Wed Jul  2 04:07:24 2008
@@ -88,7 +88,7 @@
         return membershipManagers;
     }
 
-    public void notifyMemberJoin(final Member member) { //TODO: ### rename this method
+    public void notifyMemberJoin(final Member member) { 
 
         if (Arrays.equals(loadBalancerDomain, member.getDomain())) {  // A peer load balancer
has joined. Need to send it the entire member lists
             for (MembershipManager manager : membershipManagers) {
@@ -105,12 +105,15 @@
                             MemberJoinedCommand cmd = new MemberJoinedCommand();
                             cmd.setMember(member);
                             try {
-                                manager.getRpcMembershipChannel().send(primaryMembershipManager.getMembers(),
-                                                                       cmd,
-                                                                       RpcChannel.ALL_REPLY,
Channel.SEND_OPTIONS_ASYNCHRONOUS,
-                                                                       10000);
+                                RpcChannel rpcChannel = manager.getRpcMembershipChannel();
+                                rpcChannel.send(primaryMembershipManager.getMembers(),
+                                                cmd,
+                                                RpcChannel.ALL_REPLY,
+                                                Channel.SEND_OPTIONS_ASYNCHRONOUS,
+                                                10000);
                             } catch (ChannelException e) {
-                                String errMsg = "Could not send MEMBER_JOINED[" + TribesUtil.getName(member)
+
+                                String errMsg = "Could not send MEMBER_JOINED[" +
+                                                TribesUtil.getName(member) +
                                                 "] to all load balancer members ";
                                 log.error(errMsg, e);
                                 throw new RemoteProcessException(errMsg, e);



Mime
View raw message