svn commit: r696236 - /webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java

Author: mckierna
Date: Wed Sep 17 04:00:13 2008
New Revision: 696236

URL: http://svn.apache.org/viewvc?rev=696236&view=rev
Log:
only check ack rules for application msgs

Modified:
    webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java

Modified: webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java?rev=696236&r1=696235&r2=696236&view=diff
==============================================================================
--- webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java (original)
+++ webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AcknowledgementProcessor.java Wed Sep 17 04:00:13 2008
@@ -157,9 +157,9 @@
 						
 						numberOfNewMessagesAcked++;
 						SenderBean retransmitterBean = retransmitterMgr.retrieve(outSequenceId, messageNo);						
-						if (retransmitterBean != null) {
-							// Check we haven't got an Ack for a message that hasn't been sent yet !
-							if (retransmitterBean.getSentCount() == 0) {
+						if (retransmitterBean != null && retransmitterBean.getMessageType()==Sandesha2Constants.MessageTypes.APPLICATION) {
+							// Check we haven't got an Ack for an application message that hasn't been sent yet !
+							if (retransmitterBean.getSentCount() == 0 ) {
 								FaultManager.makeInvalidAcknowledgementFault(rmMsgCtx, sequenceAck, ackRange,
 										storageManager, piggybackedAck, null); //do not want to send the fault to acksTo in this case
 								if (log.isDebugEnabled())