svn commit: r576833 - in /webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors: AckRequestedProcessor.java CloseSequenceProcessor.java SequenceProcessor.java

[mckierna]

Author: mckierna
Date: Tue Sep 18 03:47:01 2007
New Revision: 576833

URL: http://svn.apache.org/viewvc?rev=576833&view=rev
Log:
guard against null beans

Modified:
    
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java
    
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CloseSequenceProcessor.java
    
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/AckRequestedProcessor.java
URL: 
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java?rev=576833&r1=576832&r2=576833&view=diff
==============================================================================
--- 
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java
 (original)
+++ 
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/AckRequestedProcessor.java
 Tue Sep 18 03:47:01 2007
@@ -132,7 +132,7 @@
                }
 
                // Check that the sequence requested exists
-               if (FaultManager.checkForUnknownSequence(rmMsgCtx, sequenceId, 
storageManager, piggybackedAckRequest)) {
+               if (rmdBean == null || 
FaultManager.checkForUnknownSequence(rmMsgCtx, sequenceId, storageManager, 
piggybackedAckRequest)) {
                        if (log.isDebugEnabled())
                                log.debug("Exit: 
AckRequestedProcessor::processAckRequestedHeader, Unknown sequence ");
                        return false;

Modified: 
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CloseSequenceProcessor.java
URL: 
http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CloseSequenceProcessor.java?rev=576833&r1=576832&r2=576833&view=diff
==============================================================================
--- 
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CloseSequenceProcessor.java
 (original)
+++ 
webservices/sandesha/trunk/java/modules/core/src/main/java/org/apache/sandesha2/msgprocessors/CloseSequenceProcessor.java
 Tue Sep 18 03:47:01 2007
@@ -83,7 +83,7 @@
                        secManager.checkProofOfPossession(token, body, msgCtx);
                }
 
-               if (FaultManager.checkForUnknownSequence(rmMsgCtx, sequenceId, 
storageManager, false)) {
+               if (rmdBean == null || 
FaultManager.checkForUnknownSequence(rmMsgCtx, sequenceId, storageManager, 
false)) {
                        if (log.isDebugEnabled())
                                log.debug("Exit: 
CloseSequenceProcessor::processInMessage, Unknown sequence " + sequenceId);
                        return false;

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=576833&r1=576832&r2=576833&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
 Tue Sep 18 03:47:01 2007
@@ -142,7 +142,7 @@
                        throw new SandeshaException(message);
                }
 
-               if (FaultManager.checkForUnknownSequence(rmMsgCtx, sequenceId, 
storageManager, false)) {
+               if (bean==null && 
FaultManager.checkForUnknownSequence(rmMsgCtx, sequenceId, storageManager, 
false)) {
                        if (log.isDebugEnabled())
                                log.debug("Exit: 
SequenceProcessor::processReliableMessage, Unknown sequence");
                        return InvocationResponse.ABORT;



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