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