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/03/20 16:22:53 UTC
svn commit: r520428 -
/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/configuration/TribesConfigurationManager.java
Author: azeez
Date: Tue Mar 20 08:22:52 2007
New Revision: 520428
URL: http://svn.apache.org/viewvc?view=rev&rev=520428
Log:
Send configuration changed messages to self. Moving the relevant code out of the condition check
Modified:
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/configuration/TribesConfigurationManager.java
Modified: webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/configuration/TribesConfigurationManager.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/configuration/TribesConfigurationManager.java?view=diff&rev=520428&r1=520427&r2=520428
==============================================================================
--- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/configuration/TribesConfigurationManager.java (original)
+++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/configuration/TribesConfigurationManager.java Tue Mar 20 08:22:52 2007
@@ -23,10 +23,10 @@
import org.apache.axis2.cluster.tribes.ChannelSender;
import org.apache.axis2.cluster.tribes.CommandType;
import org.apache.axis2.engine.AxisConfiguration;
-import org.apache.neethi.Policy;
import org.apache.catalina.tribes.Channel;
-import org.apache.catalina.tribes.Member;
import org.apache.catalina.tribes.ChannelException;
+import org.apache.catalina.tribes.Member;
+import org.apache.neethi.Policy;
import java.util.ArrayList;
import java.util.Iterator;
@@ -93,15 +93,15 @@
Channel channel = sender.getChannel();
if (channel.getMembers().length > 0) {
sender.send(command);
+ }
- // Need to send the message to self too
- try {
- channel.send(new Member[]{channel.getLocalMember(true)},
- command,
- 0);
- } catch (ChannelException e) {
- throw new ClusteringFault(e);
- }
+ // Need to send the message to self too
+ try {
+ channel.send(new Member[]{channel.getLocalMember(true)},
+ command,
+ 0);
+ } catch (ChannelException e) {
+ throw new ClusteringFault(e);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org