Commit 545031b5 authored by Aurel's avatar Aurel

delete message for the method id given in parameter to flush

git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@13243 20353a03-c40f-0410-a6d1-a30d3c3de9de
parent 4215f656
...@@ -423,12 +423,12 @@ class SQLDict(RAMDict): ...@@ -423,12 +423,12 @@ class SQLDict(RAMDict):
processing_node=None,include_processing=0) processing_node=None,include_processing=0)
for line in result: for line in result:
path = line.path path = line.path
method_id = line.method_id line_method_id = line.method_id
if not method_dict.has_key(method_id): if not method_dict.has_key(line_method_id):
# Only invoke once (it would be different for a queue) # Only invoke once (it would be different for a queue)
# This is optimisation with the goal to process objects on the same # This is optimisation with the goal to process objects on the same
# node and minimize network traffic with ZEO server # node and minimize network traffic with ZEO server
method_dict[method_id] = 1 method_dict[line_method_id] = 1
m = self.loadMessage(line.message, uid = line.uid) m = self.loadMessage(line.message, uid = line.uid)
if invoke: if invoke:
# First Validate # First Validate
...@@ -450,7 +450,7 @@ class SQLDict(RAMDict): ...@@ -450,7 +450,7 @@ class SQLDict(RAMDict):
'Could not validate %s on %s' % (m.method_id , path)) 'Could not validate %s on %s' % (m.method_id , path))
if len(result): if len(result):
uid_list = activity_tool.SQLDict_readUidList(path = path, method_id = None, uid_list = activity_tool.SQLDict_readUidList(path = path, method_id = method_id,
processing_node = None,) processing_node = None,)
activity_tool.SQLDict_delMessage(uid = [x.uid for x in uid_list]) activity_tool.SQLDict_delMessage(uid = [x.uid for x in uid_list])
......
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