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:17:44 UTC
svn commit: r520426 - in
/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes:
TribesClusterManager.java configuration/TribesConfigurationManager.java
Author: azeez
Date: Tue Mar 20 08:17:43 2007
New Revision: 520426
URL: http://svn.apache.org/viewvc?view=rev&rev=520426
Log:
Send configuration changed messages to self
Modified:
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/TribesClusterManager.java
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/TribesClusterManager.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/TribesClusterManager.java?view=diff&rev=520426&r1=520425&r2=520426
==============================================================================
--- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/TribesClusterManager.java (original)
+++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/cluster/tribes/TribesClusterManager.java Tue Mar 20 08:17:43 2007
@@ -37,10 +37,9 @@
public class TribesClusterManager implements ClusterManager {
-
- TribesConfigurationManager configurationManager = null;
- TribesContextManager contextManager = null;
- ConfigurationContext configContext = null;
+ private TribesConfigurationManager configurationManager = null;
+ private TribesContextManager contextManager = null;
+ private ConfigurationContext configContext = null;
private ContextUpdater updater;
private static long timeout = 1000L; // this should be configured in the axis2.xml
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=520426&r1=520425&r2=520426
==============================================================================
--- 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:17:43 2007
@@ -24,6 +24,9 @@
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 java.util.ArrayList;
import java.util.Iterator;
@@ -87,8 +90,18 @@
}
private void send(ConfigurationCommand command) throws ClusteringFault {
- if (sender.getChannel().getMembers().length > 0) {
+ 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);
+ }
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org