[Erp5-report] r18755 - in /erp5/trunk/products/CMFActivity/Activity: SQLDict.py SQLQueue.py

[nobody at svn.erp5.org]

Author: yo
Date: Thu Jan 17 08:51:22 2008
New Revision: 18755

URL: http://svn.erp5.org?rev=18755&view=rev
Log:
Override finishQueueMessage and finishDeleteMessage to do nothing in SQLQueue and SQLDict. Otherwise, messages are accumulated in RAM infinitely, due to RAMDict and RAMQueue.

Modified:
    erp5/trunk/products/CMFActivity/Activity/SQLDict.py
    erp5/trunk/products/CMFActivity/Activity/SQLQueue.py

Modified: erp5/trunk/products/CMFActivity/Activity/SQLDict.py
URL: http://svn.erp5.org/erp5/trunk/products/CMFActivity/Activity/SQLDict.py?rev=18755&r1=18754&r2=18755&view=diff
==============================================================================
--- erp5/trunk/products/CMFActivity/Activity/SQLDict.py (original)
+++ erp5/trunk/products/CMFActivity/Activity/SQLDict.py Thu Jan 17 08:51:22 2008
@@ -99,6 +99,14 @@
     uid_list = [x.uid for x in uid_list]
     if len(uid_list)>0:
       activity_tool.SQLDict_delMessage(uid = uid_list)
+
+  def finishQueueMessage(self, activity_tool_path, m):
+    # Nothing to do in SQLDict.
+    pass
+
+  def finishDeleteMessage(self, activity_tool_path, m):
+    # Nothing to do in SQLDict.
+    pass
 
   # Registration management
   def registerActivityBuffer(self, activity_buffer):

Modified: erp5/trunk/products/CMFActivity/Activity/SQLQueue.py
URL: http://svn.erp5.org/erp5/trunk/products/CMFActivity/Activity/SQLQueue.py?rev=18755&r1=18754&r2=18755&view=diff
==============================================================================
--- erp5/trunk/products/CMFActivity/Activity/SQLQueue.py (original)
+++ erp5/trunk/products/CMFActivity/Activity/SQLQueue.py Thu Jan 17 08:51:22 2008
@@ -83,6 +83,14 @@
     # Erase all messages in a single transaction
     #LOG("prepareDeleteMessage", 0, str(m.__dict__))
     activity_tool.SQLQueue_delMessage(uid = [m.uid])
+
+  def finishQueueMessage(self, activity_tool_path, m):
+    # Nothing to do in SQLQueue.
+    pass
+
+  def finishDeleteMessage(self, activity_tool_path, m):
+    # Nothing to do in SQLQueue.
+    pass
 
   def getReservedMessageList(self, activity_tool, date, processing_node, limit=None):
     """