Author: gatfora Date: Tue Nov 28 04:54:24 2006 New Revision: 480028 URL: http://svn.apache.org/viewvc?view=rev&rev=480028 Log: Make sendAckIfNeeded static so SandeshaGlobalInHandler doesn't have to new a SequenceProcessor object to call it
Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/SequenceProcessor.java Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java?view=diff&rev=480028&r1=480027&r2=480028 ============================================================================== --- webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java (original) +++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/handlers/SandeshaGlobalInHandler.java Tue Nov 28 04:54:24 2006 @@ -39,7 +39,6 @@ import org.apache.sandesha2.SandeshaException; import org.apache.sandesha2.i18n.SandeshaMessageHelper; import org.apache.sandesha2.i18n.SandeshaMessageKeys; -import org.apache.sandesha2.msgprocessors.ApplicationMsgProcessor; import org.apache.sandesha2.msgprocessors.SequenceProcessor; import org.apache.sandesha2.storage.StorageManager; import org.apache.sandesha2.storage.Transaction; @@ -276,9 +275,7 @@ seqPropMgr.update(receivedMsgsBean); - SequenceProcessor processor = new SequenceProcessor(); - processor.sendAckIfNeeded(rmMsgContext, receivedMsgStr, storageManager); - + SequenceProcessor.sendAckIfNeeded(rmMsgContext, receivedMsgStr, storageManager); drop = true; @@ -346,8 +343,7 @@ // Even though the duplicate message is dropped, hv to send the ack // if needed. - SequenceProcessor processor = new SequenceProcessor(); - processor.sendAckIfNeeded(rmMsgContext, receivedMsgStr, storageManager); + SequenceProcessor.sendAckIfNeeded(rmMsgContext, receivedMsgStr, storageManager); } if (log.isDebugEnabled()) Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/SequenceProcessor.java URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/SequenceProcessor.java?view=diff&rev=480028&r1=480027&r2=480028 ============================================================================== --- webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/SequenceProcessor.java (original) +++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/msgprocessors/SequenceProcessor.java Tue Nov 28 04:54:24 2006 @@ -294,7 +294,7 @@ return false; } - public void sendAckIfNeeded(RMMsgContext rmMsgCtx, String messagesStr, StorageManager storageManager) + public static void sendAckIfNeeded(RMMsgContext rmMsgCtx, String messagesStr, StorageManager storageManager) throws AxisFault { if (log.isDebugEnabled()) --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]
