Author: gatfora
Date: Tue Dec  5 02:32:48 2006
New Revision: 482575

URL: http://svn.apache.org/viewvc?view=rev&rev=482575
Log:
Applying NPE patch for SANDESHA2-59

Modified:
    
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java

Modified: 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java
URL: 
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java?view=diff&rev=482575&r1=482574&r2=482575
==============================================================================
--- 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java
 (original)
+++ 
webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java
 Tue Dec  5 02:32:48 2006
@@ -53,6 +53,7 @@
 import org.apache.sandesha2.storage.beans.CreateSeqBean;
 import org.apache.sandesha2.storage.beans.SenderBean;
 import org.apache.sandesha2.storage.beans.SequencePropertyBean;
+import org.apache.sandesha2.util.FaultManager;
 import org.apache.sandesha2.util.MsgInitializer;
 import org.apache.sandesha2.util.RMMsgCreator;
 import org.apache.sandesha2.util.SOAPAbstractFactory;
@@ -132,6 +133,20 @@
                        SecurityToken token = 
secManager.recoverSecurityToken(tokenBean.getValue());
                        
                        secManager.checkProofOfPossession(token, soapHeader, 
msgContext);
+               }
+
+               // Check that the sequence requested exists
+               FaultManager faultManager = new FaultManager();
+               SandeshaException fault = 
faultManager.checkForUnknownSequence(rmMsgCtx, sequenceId, storageManager);
+               if (fault != null) {
+                       throw fault;
+               }
+
+               // Check that the sequence isn't closed
+               // throwing a fault if the sequence is closed.
+               fault = faultManager.checkForSequenceClosed(rmMsgCtx, 
sequenceId, storageManager);
+               if (fault != null) {
+                       throw fault;
                }
 
                // Setting the ack depending on AcksTo.



---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]

Reply via email to