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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
