[prev in list] [next in list] [prev in thread] [next in thread] 

List:       sandesha-dev
Subject:    svn commit: r672752 -
From:       gatfora () apache ! org
Date:       2008-06-30 12:50:39
Message-ID: 20080630125039.6327223889C4 () eris ! apache ! org
[Download RAW message or body]

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/mai \
n/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: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org


[prev in list] [next in list] [prev in thread] [next in thread]