You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by ga...@apache.org on 2006/12/05 11:32:49 UTC
svn commit: r482575 -
/webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java
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: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org