Author: gatfora
Date: Mon Jun 30 05:50:38 2008
New Revision: 672752
URL: http://svn.apache.org/viewvc?rev=672752&view=rev
Log:
Commiting missing part from SANDESHA2-164
Modified:
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/SequenceProcessor.java
Modified:
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/SequenceProcessor.java
URL:
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/SequenceProcessor.java?rev=672752&r1=672751&r2=672752&view=diff
==============================================================================
---
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/SequenceProcessor.java
(original)
+++
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/SequenceProcessor.java
Mon Jun 30 05:50:38 2008
@@ -57,6 +57,7 @@
import org.apache.sandesha2.util.SpecSpecificConstants;
import org.apache.sandesha2.util.TerminateManager;
import org.apache.sandesha2.workers.InvokerWorker;
+import org.apache.sandesha2.workers.Sender;
import org.apache.sandesha2.wsrm.Sequence;
/**
@@ -339,11 +340,8 @@
} else if (!acksTo.hasAnonymousAddress()) {
SandeshaPolicyBean policyBean =
SandeshaUtil.getPropertyBean (msgCtx.getAxisOperation());
long ackInterval =
policyBean.getAcknowledgementInterval();
- long timeToSend = System.currentTimeMillis() +
ackInterval;
- RMMsgContext ackRMMsgContext =
AcknowledgementManager.generateAckMessage(rmMsgCtx, bean, sequenceId,
storageManager,true);
-
- AcknowledgementManager.addAckBeanEntry(ackRMMsgContext,
sequenceId, timeToSend, storageManager);
+
((Sender)storageManager.getSender()).scheduleAddressableAcknowledgement(sequenceId,
ackInterval, rmMsgCtx);
// If the MEP doesn't need the backchannel, and nor do
we, we should signal it so that it
// can close off as soon as possible.
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
