Commit c0d10c5e authored by Alexandre Boeglin's avatar Alexandre Boeglin

Rollback previous patch : it would have done strange things in cluster mode.


git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@5665 20353a03-c40f-0410-a6d1-a30d3c3de9de
parent 6c1432b7
...@@ -63,13 +63,6 @@ class SQLDict(RAMDict): ...@@ -63,13 +63,6 @@ class SQLDict(RAMDict):
and provide sequentiality. Should not create conflict and provide sequentiality. Should not create conflict
because use of OOBTree. because use of OOBTree.
""" """
def initialize(self, activity_tool):
if not self.is_initialized:
# If zope was stopped while activities where processed we must mark them
# as unprocessed, or they will be kept as zombies in the SQL table
activity_tool.SQLDict_clearProcessingFlag()
self.is_initialized = 1
# Transaction commit methods # Transaction commit methods
def prepareQueueMessage(self, activity_tool, m): def prepareQueueMessage(self, activity_tool, m):
if m.is_registered: if m.is_registered:
......
...@@ -58,13 +58,6 @@ class SQLQueue(RAMQueue): ...@@ -58,13 +58,6 @@ class SQLQueue(RAMQueue):
and provide sequentiality. Should not create conflict and provide sequentiality. Should not create conflict
because use of OOBTree. because use of OOBTree.
""" """
def initialize(self, activity_tool):
if not self.is_initialized:
# If zope was stopped while activities where processed we must mark them
# as unprocessed, or they will be kept as zombies in the SQL table
activity_tool.SQLQueue_clearProcessingFlag()
self.is_initialized = 1
def prepareQueueMessage(self, activity_tool, m): def prepareQueueMessage(self, activity_tool, m):
if m.is_registered: if m.is_registered:
activity_tool.SQLQueue_writeMessage(path = '/'.join(m.object_path) , activity_tool.SQLQueue_writeMessage(path = '/'.join(m.object_path) ,
......
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