You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by ga...@apache.org on 2007/03/13 18:22:35 UTC

svn commit: r517783 - /webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java

Author: gatfora
Date: Tue Mar 13 10:22:34 2007
New Revision: 517783

URL: http://svn.apache.org/viewvc?view=rev&rev=517783
Log:
Minor tweak to duplicate processing to enable message to reach the RMMessageReceiver so ACK messages can be sent.

Modified:
    webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java

Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java?view=diff&rev=517783&r1=517782&r2=517783
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java Tue Mar 13 10:22:34 2007
@@ -176,6 +176,9 @@
           storageManager.getRMDBeanMgr().update(bean);
         }
         else {
+          if (log.isDebugEnabled())
+            log.debug("Detected duplicate message " + msgNo);
+          rmMsgCtx.getMessageContext().setRelationships(null);
           // Add the duplicate RM AxisOperation to the message
           AxisOperation duplicateMessageOperation = SpecSpecificConstants.getWSRMOperation(
               Sandesha2Constants.MessageTypes.DUPLICATE_MESSAGE,
@@ -185,6 +188,9 @@
         }
               
       } else {
+        if (log.isDebugEnabled())
+          log.debug("Detected message for no sequence " + msgNo);
+        rmMsgCtx.getMessageContext().setRelationships(null);
         // Add the duplicate RM AxisOperation to the message
         AxisOperation duplicateMessageOperation = SpecSpecificConstants.getWSRMOperation(
             Sandesha2Constants.MessageTypes.DUPLICATE_MESSAGE,



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