diff --git a/product/CMFActivity/Activity/SQLQueue.py b/product/CMFActivity/Activity/SQLQueue.py index ccb2f7f24f95b7a94f62891e4d7bafba3a5255e0..c09fc193cf4cd7cf00a45e00fb6ad921555a09f0 100644 --- a/product/CMFActivity/Activity/SQLQueue.py +++ b/product/CMFActivity/Activity/SQLQueue.py @@ -422,14 +422,6 @@ class SQLQueue(RAMQueue, SQLBase): if len(result): activity_tool.SQLQueue_delMessage(uid = [line.uid for line in result]) - # 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 getMessageList(self, activity_tool, processing_node=None,**kw): message_list = [] readMessageList = getattr(activity_tool, 'SQLQueue_readMessageList', None)