svn commit: r527506 - /webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/SequenceProcessor.java

[ga...@apache.org]

Author: gatfora
Date: Wed Apr 11 07:44:52 2007
New Revision: 527506

URL: http://svn.apache.org/viewvc?view=rev&rev=527506
Log:
Use the Sandesha2Constant for the RMDuplicate operation.  This fixes a problem where acks are not sent for duplicate messages.

Modified:
    webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/SequenceProcessor.java

Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/SequenceProcessor.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/SequenceProcessor.java?view=diff&rev=527506&r1=527505&r2=527506
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/SequenceProcessor.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/SequenceProcessor.java Wed Apr 11 07:44:52 2007
@@ -195,7 +195,7 @@
 		}
 		
 		String specVersion = rmMsgCtx.getRMSpecVersion();
-		if (rmMsgCtx.getMessageContext().getAxisOperation().getName().getLocalPart().equals("RMInOutDuplicateMessageOperation")
+		if (rmMsgCtx.getMessageContext().getAxisOperation().getName().getLocalPart().equals(Sandesha2Constants.RM_DUPLICATE_OPERATION.getLocalPart())
 				&& (Sandesha2Constants.QOS.InvocationType.DEFAULT_INVOCATION_TYPE == Sandesha2Constants.QOS.InvocationType.EXACTLY_ONCE)) {
 			// this is a duplicate message and the invocation type is EXACTLY_ONCE. We try to return
 			// ack messages at this point, as if someone is sending duplicates then they may have



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