Commit d84be783 authored by Jean-Paul Smets's avatar Jean-Paul Smets

Do not call invoke twice in flush


git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@346 20353a03-c40f-0410-a6d1-a30d3c3de9de
parent 0b591734
......@@ -147,14 +147,6 @@ class SQLDict(RAMDict):
valid = 0
retry=MAX_RETRY
if valid: # We should validate each time XXX in case someone is deleting it at the same time
retry = 0
while retry < MAX_RETRY:
activity_tool.invoke(m) # Try to invoke the message
if m.is_executed:
retry=MAX_RETRY
else:
get_transaction().abort() # Abort and retry
retry = retry + 1
if m.is_executed: # Make sure message could be invoked
activity_tool.SQLDict_delMessage(path=path, method_id=method_id, processing_node=None) # Delete it
if commit: get_transaction().commit() # If successful, commit
......
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