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/11/12 16:16:04 UTC
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
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