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/07/02 13:07:25 UTC
svn commit: r673357 -
/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/LoadBalancerMode.java
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);