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 ml...@apache.org on 2007/01/31 12:35:13 UTC
svn commit: r501809 -
/webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/TerminateManager.java
Author: mlovett
Date: Wed Jan 31 03:35:12 2007
New Revision: 501809
URL: http://svn.apache.org/viewvc?view=rev&rev=501809
Log:
Stop deleting RMD beans, until we can implement a proper timeout mechanism
Modified:
webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/TerminateManager.java
Modified: webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/TerminateManager.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/TerminateManager.java?view=diff&rev=501809&r1=501808&r2=501809
==============================================================================
--- webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/TerminateManager.java (original)
+++ webservices/sandesha/trunk/java/src/org/apache/sandesha2/util/TerminateManager.java Wed Jan 31 03:35:12 2007
@@ -81,6 +81,8 @@
while (ackBeans.hasNext()) {
SenderBean ackBean = (SenderBean) ackBeans.next();
senderBeanMgr.delete(ackBean.getMessageID());
+
+ storageManager.removeMessageContext(ackBean.getMessageContextRefKey());
}
// Currently in-order invocation is done for default values.
@@ -152,16 +154,20 @@
private static void completeTerminationOfReceivingSide(ConfigurationContext configContext, String sequencePropertyKey,String sequenceId,
StorageManager storageManager) throws SandeshaException {
- // removing nextMsgMgr entries
- RMDBeanMgr rMDBeanMgr = storageManager.getRMDBeanMgr();
- RMDBean findNextMsgBean = new RMDBean();
- findNextMsgBean.setSequenceID(sequenceId);
- Collection collection = rMDBeanMgr.find(findNextMsgBean);
- Iterator iterator = collection.iterator();
- while (iterator.hasNext()) {
- RMDBean rMDBean = (RMDBean) iterator.next();
- rMDBeanMgr.delete(rMDBean.getSequenceID());
- }
+ // TODO We need to remove the RMDBean, but doing so quickly can stop
+ // the user from calling the sequence report to discover the state of
+ // the sequence. We should impement something with a little more delay,
+ // perhaps a few minutes.
+// // removing nextMsgMgr entries
+// RMDBeanMgr rMDBeanMgr = storageManager.getRMDBeanMgr();
+// RMDBean findNextMsgBean = new RMDBean();
+// findNextMsgBean.setSequenceID(sequenceId);
+// Collection collection = rMDBeanMgr.find(findNextMsgBean);
+// Iterator iterator = collection.iterator();
+// while (iterator.hasNext()) {
+// RMDBean rMDBean = (RMDBean) iterator.next();
+// rMDBeanMgr.delete(rMDBean.getSequenceID());
+// }
}
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org