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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
