axis-java-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From az...@apache.org
Subject svn commit: r594176 - in /webservices/axis2/trunk/java/modules: adb/src/org/apache/axis2/rpc/receivers/RPCInOnlyMessageReceiver.java clustering/src/org/apache/axis2/clustering/tribes/ChannelListener.java
Date Mon, 12 Nov 2007 15:16:04 GMT
Author: azeez
Date: Mon Nov 12 07:16:03 2007
New Revision: 594176

URL: http://svn.apache.org/viewvc?rev=594176&view=rev
Log:
Replicate state after calling business logic in RPCInOnlyMessageReceiver


Modified:
    webservices/axis2/trunk/java/modules/adb/src/org/apache/axis2/rpc/receivers/RPCInOnlyMessageReceiver.java
    webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/ChannelListener.java

Modified: webservices/axis2/trunk/java/modules/adb/src/org/apache/axis2/rpc/receivers/RPCInOnlyMessageReceiver.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/adb/src/org/apache/axis2/rpc/receivers/RPCInOnlyMessageReceiver.java?rev=594176&r1=594175&r2=594176&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/adb/src/org/apache/axis2/rpc/receivers/RPCInOnlyMessageReceiver.java
(original)
+++ webservices/axis2/trunk/java/modules/adb/src/org/apache/axis2/rpc/receivers/RPCInOnlyMessageReceiver.java
Mon Nov 12 07:16:03 2007
@@ -66,6 +66,7 @@
                         methodElement,inMessage);
 
             }
+            replicateState(inMessage);
         } catch (InvocationTargetException e) {
             Throwable cause = e.getCause();
             if (cause != null) {

Modified: webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/ChannelListener.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/ChannelListener.java?rev=594176&r1=594175&r2=594176&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/ChannelListener.java
(original)
+++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/ChannelListener.java
Mon Nov 12 07:16:03 2007
@@ -77,6 +77,7 @@
     }
 
     public void messageReceived(Serializable msg, Member sender) {
+        log.debug("RECEIVED MESSAGE " + msg + " from " + TribesUtil.getHost(sender));
 
         // If the system has not still been intialized, reject all incoming messages, except
the
         // GetStateResponseCommand message
@@ -84,6 +85,8 @@
                 getPropertyNonReplicable(ClusteringConstants.CLUSTER_INITIALIZED) == null
             && !(msg instanceof GetStateResponseCommand) &&
             !(msg instanceof GetConfigurationResponseCommand)) {
+
+            log.warn("Received message before cluster initialization has been completed");
             return;
         }
         log.debug("RECEIVED MESSAGE " + msg + " from " + TribesUtil.getHost(sender));
@@ -95,6 +98,9 @@
     }
 
     private void processMessage(Serializable msg, Member sender) throws ClusteringFault {
+        //TODO: Reject duplicates that can be received due to retransmissions
+        //TODO: ACK implosion?
+
         if (msg instanceof ContextClusteringCommand && contextManager != null) {
             ContextClusteringCommand ctxCmd = (ContextClusteringCommand) msg;
             contextManager.process(ctxCmd);



---------------------------------------------------------------------
To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org


Mime
View raw message