You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by Andrew K Gatford <GA...@uk.ibm.com> on 2006/11/28 13:59:45 UTC
svn commit: r480028 - in /webservices/sandesha/trunk/java/src/org/apache/sandesha2: handlers/SandeshaGlobalInHandler.java
msgprocessors/SequenceProcessor.java
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: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org