Commit e1a7d9a4 authored by Sebastien Robin's avatar Sebastien Robin

corrected bug when flushing ramdict


git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@703 20353a03-c40f-0410-a6d1-a30d3c3de9de
parent 87b443d8
...@@ -109,14 +109,10 @@ class RAMDict(Queue): ...@@ -109,14 +109,10 @@ class RAMDict(Queue):
'The document %s does not exist' % path) 'The document %s does not exist' % path)
# Parse each message in RAM dict # Parse each message in RAM dict
for key, m in self.dict.items(): for key, m in self.dict.items():
if not m.is_deleted:
if object_path == m.object_path and (method_id is None or method_id == m.method_id): if object_path == m.object_path and (method_id is None or method_id == m.method_id):
LOG('CMFActivity RAMDict: ', 0, 'flushing object %s' % '/'.join(m.object_path)) LOG('CMFActivity RAMDict: ', 0, 'flushing object %s' % '/'.join(m.object_path))
if invoke: activity_tool.invoke(m) if invoke: activity_tool.invoke(m)
self.deleteMessage(activity_tool, m) self.deleteMessage(activity_tool, m)
else:
pass
#LOG('CMFActivity RAMDict: ', 0, 'not flushing object %s' % '/'.join(m.object_path))
def getMessageList(self, activity_tool, processing_node=None): def getMessageList(self, activity_tool, processing_node=None):
return self.dict.values() return self.dict.values()
......
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