From 392dd9b29fc66cbd789d5159e01cea4555473da2 Mon Sep 17 00:00:00 2001 From: Jean-Paul Smets <jp@nexedi.com> Date: Wed, 21 Apr 2004 13:45:15 +0000 Subject: [PATCH] start and stop commented out git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@709 20353a03-c40f-0410-a6d1-a30d3c3de9de --- product/CMFActivity/Activity/SQLDict.py | 12 ++++++------ product/CMFActivity/Activity/SQLQueue.py | 12 ++++++------ 2 files changed, 12 insertions(+), 12 deletions(-) diff --git a/product/CMFActivity/Activity/SQLDict.py b/product/CMFActivity/Activity/SQLDict.py index 5971b51a1b..4a05d6afac 100755 --- a/product/CMFActivity/Activity/SQLDict.py +++ b/product/CMFActivity/Activity/SQLDict.py @@ -220,13 +220,13 @@ class SQLDict(RAMDict): raise ActivityFlushError, ( 'The document %s does not exist' % path) - def start(self, activity_tool, active_process=None): - uid_list = activity_tool.SQLDict_readUidList(path=path, active_process=active_process) - activity_tool.SQLDict_assignMessage(uid = uid_list, processing_node = DISTRIBUTABLE_STATE) + # def start(self, activity_tool, active_process=None): + # uid_list = activity_tool.SQLDict_readUidList(path=path, active_process=active_process) + # activity_tool.SQLDict_assignMessage(uid = uid_list, processing_node = DISTRIBUTABLE_STATE) - def stop(self, activity_tool, active_process=None): - uid_list = activity_tool.SQLDict_readUidList(path=path, active_process=active_process) - activity_tool.SQLDict_assignMessage(uid = uid_list, processing_node = STOP_STATE) + # def stop(self, activity_tool, active_process=None): + # uid_list = activity_tool.SQLDict_readUidList(path=path, active_process=active_process) + # activity_tool.SQLDict_assignMessage(uid = uid_list, processing_node = STOP_STATE) def getMessageList(self, activity_tool, processing_node=None): # YO: reading all lines might cause a deadlock diff --git a/product/CMFActivity/Activity/SQLQueue.py b/product/CMFActivity/Activity/SQLQueue.py index 6ce026b105..437a5ebd81 100755 --- a/product/CMFActivity/Activity/SQLQueue.py +++ b/product/CMFActivity/Activity/SQLQueue.py @@ -164,13 +164,13 @@ class SQLQueue(RAMQueue): raise ActivityFlushError, ( 'The document %s does not exist' % path) - def start(self, activity_tool, active_process=None): - uid_list = activity_tool.SQLQueue_readUidList(path=path, active_process=active_process) - activity_tool.SQLQueue_assignMessage(uid = uid_list, processing_node = DISTRIBUTABLE_STATE) + # def start(self, activity_tool, active_process=None): + # uid_list = activity_tool.SQLQueue_readUidList(path=path, active_process=active_process) + # activity_tool.SQLQueue_assignMessage(uid = uid_list, processing_node = DISTRIBUTABLE_STATE) - def stop(self, activity_tool, active_process=None): - uid_list = activity_tool.SQLQueue_readUidList(path=path, active_process=active_process) - activity_tool.SQLQueue_assignMessage(uid = uid_list, processing_node = STOP_STATE) + # def stop(self, activity_tool, active_process=None): + # uid_list = activity_tool.SQLQueue_readUidList(path=path, active_process=active_process) + # activity_tool.SQLQueue_assignMessage(uid = uid_list, processing_node = STOP_STATE) def getMessageList(self, activity_tool, processing_node=None): message_list = [] -- 2.30.9