Commit 02294ec2 authored by Yoshinori Okuji's avatar Yoshinori Okuji

Override finishQueueMessage and finishDeleteMessage to do nothing in SQLQueue...

Override finishQueueMessage and finishDeleteMessage to do nothing in SQLQueue and SQLDict. Otherwise, messages are accumulated in RAM infinitely, due to RAMDict and RAMQueue.

git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@18755 20353a03-c40f-0410-a6d1-a30d3c3de9de
parent c797d458
No related merge requests found
...@@ -100,6 +100,14 @@ class SQLDict(RAMDict, SQLBase): ...@@ -100,6 +100,14 @@ class SQLDict(RAMDict, SQLBase):
if len(uid_list)>0: if len(uid_list)>0:
activity_tool.SQLDict_delMessage(uid = uid_list) 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 # Registration management
def registerActivityBuffer(self, activity_buffer): def registerActivityBuffer(self, activity_buffer):
pass pass
......
...@@ -84,6 +84,14 @@ class SQLQueue(RAMQueue, SQLBase): ...@@ -84,6 +84,14 @@ class SQLQueue(RAMQueue, SQLBase):
#LOG("prepareDeleteMessage", 0, str(m.__dict__)) #LOG("prepareDeleteMessage", 0, str(m.__dict__))
activity_tool.SQLQueue_delMessage(uid = [m.uid]) 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): def getReservedMessageList(self, activity_tool, date, processing_node, limit=None):
""" """
Get and reserve a list of messages. Get and reserve a list of messages.
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment