diff --git a/product/CMFActivity/ActiveProcess.py b/product/CMFActivity/ActiveProcess.py index 0a5a206a1b5b3e0a5b1a0045cfe947716ebe4be6..ab21db551363ed9a6cdf8cebea71fd2f13ba1a3d 100755 --- a/product/CMFActivity/ActiveProcess.py +++ b/product/CMFActivity/ActiveProcess.py @@ -80,7 +80,7 @@ class ActiveProcess(Base): # Base methods security.declareProtected(CMFCorePermissions.ManagePortal, 'postError') def postError(self, error): - self.error_list = self.get('error_list', []) + [error] + self.error_list = getattr(self, 'error_list', []) + [error] security.declareProtected(CMFCorePermissions.ManagePortal, 'getErrorList') def getErrorList(self): @@ -99,7 +99,9 @@ class ActiveProcess(Base): security.declareProtected(CMFCorePermissions.ManagePortal, 'activateResult') def activateResult(self, result): if result not in (None, 0, '', (), []): - self.activate().postError(result) + #self.activate().postError(result) + self.postError(result) # Until we get SQLQueue + InitializeClass( ActiveProcess ) diff --git a/product/CMFActivity/ActivityTool.py b/product/CMFActivity/ActivityTool.py index 6a18e69d3fc0b3a275e28c7d9d35b8cf1198c07a..a562dd73a2819fedbbb0c0c322d7a1b635e22646 100755 --- a/product/CMFActivity/ActivityTool.py +++ b/product/CMFActivity/ActivityTool.py @@ -174,7 +174,7 @@ class ActivityTool (Folder, UniqueObject): def initialize(self): global is_initialized - from Activity import RAMQueue, RAMDict, SQLDict + from Activity import RAMQueue, RAMDict, SQLDict, SQLQueue # Initialize each queue for activity in activity_list: activity.initialize(self) diff --git a/product/CMFActivity/zope_distribute_loop b/product/CMFActivity/zope_distribute_loop index 3f94c02fd07501ed96cf32ff4d64888c578bc815..a1ff93caae6b682816ef020022c3ccc3eb9f4fd5 100755 --- a/product/CMFActivity/zope_distribute_loop +++ b/product/CMFActivity/zope_distribute_loop @@ -1,5 +1,9 @@ #!/bin/bash while true; do -wget -O /tmp/zope_distribute.out http://jp:jp@localhost:9573/coramy/portal_activities/distribute?node_count:int=1 +wget -O /tmp/zope_distribute.out http://jp:jp@localhost:9573/coramy/portal_activities/distribute?node_count:int=3 & +#wget -O /tmp/zope_distribute.out http://jp:jp@localhost:9573/coramy/portal_activities/distribute?node_count:int=1 & +wget -O /tmp/zope_tic1.out http://jp:jp@localhost:9573/coramy/portal_activities/tic?processing_node:int=1 & +wget -O /tmp/zope_tic2.out http://jp:jp@192.1.2.150:9473/coramy/portal_activities/tic?processing_node:int=2 & +wget -O /tmp/zope_tic3.out http://jp:jp@192.1.2.150:9573/coramy/portal_activities/tic?processing_node:int=3 & sleep 5 done diff --git a/product/CMFActivity/zope_tic_loop1 b/product/CMFActivity/zope_tic_loop1 index 0025c3a7b61efc8de037010e974a2ce22dd0435a..ec5f3c50529b4cfc10de4f1424f3a68306d82700 100755 --- a/product/CMFActivity/zope_tic_loop1 +++ b/product/CMFActivity/zope_tic_loop1 @@ -1,5 +1,6 @@ #!/bin/bash while true; do -wget -O /tmp/zope_tic1.out http://jp:jp@localhost:9573/coramy/portal_activities/tic?processing_node:int=1 +wget -O /tmp/zope_tic1.out http://jp:jp@localhost:9573/coramy/portal_activities/tic?processing_node:int=1 & + sleep 5 done