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

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.