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/07/08 13:59:27 UTC
svn commit: r554352 - in
/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering:
context/ClusteringContextListener.java tribes/TribesClusterManager.java
Author: azeez
Date: Sun Jul 8 04:59:27 2007
New Revision: 554352
URL: http://svn.apache.org/viewvc?view=rev&rev=554352
Log:
Send the context removed messages
Modified:
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/context/ClusteringContextListener.java
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java
Modified: webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/context/ClusteringContextListener.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/context/ClusteringContextListener.java?view=diff&rev=554352&r1=554351&r2=554352
==============================================================================
--- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/context/ClusteringContextListener.java (original)
+++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/context/ClusteringContextListener.java Sun Jul 8 04:59:27 2007
@@ -18,20 +18,37 @@
*/
package org.apache.axis2.clustering.context;
-import org.apache.axis2.context.ContextListener;
+import org.apache.axis2.clustering.ClusteringFault;
+import org.apache.axis2.clustering.MessageSender;
import org.apache.axis2.context.AbstractContext;
+import org.apache.axis2.context.ContextListener;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
/**
*
*/
public class ClusteringContextListener implements ContextListener {
+ private static final Log log = LogFactory.getLog(ClusteringContextListener.class);
+
+ private MessageSender sender;
+
+ public ClusteringContextListener(MessageSender sender) {
+ this.sender = sender;
+ }
+
public void contextCreated(AbstractContext context) {
- //TODO: Method implementation
- System.err.println("$$$$$$$$$$$$$$ Context created: " + context);
}
public void contextRemoved(AbstractContext context) {
- //TODO: Method implementation
- System.err.println("$$$$$$$$$$$$$$ Context removed: " + context);
+ ContextClusteringCommand command =
+ ContextClusteringCommandFactory.getRemoveCommand(context);
+ if(command != null){
+ try {
+ sender.sendToGroup(command);
+ } catch (ClusteringFault e) {
+ log.error(e);
+ }
+ }
}
}
Modified: webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java?view=diff&rev=554352&r1=554351&r2=554352
==============================================================================
--- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java (original)
+++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java Sun Jul 8 04:59:27 2007
@@ -174,8 +174,7 @@
configurationContext.
setNonReplicableProperty(ClusteringConstants.CLUSTER_INITIALIZED,
"true");
- ClusteringContextListener contextListener = new ClusteringContextListener();
- //TODO: May need to set the context listener somewhere to be useful
+ ClusteringContextListener contextListener = new ClusteringContextListener(sender);
configurationContext.addContextListener(contextListener);
}
} catch (ChannelException e) {
---------------------------------------------------------------------
To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org