From 6a8ed492b3d80de2e453ebf733d91f66b44cd98e Mon Sep 17 00:00:00 2001 From: Sebastien Robin <seb@nexedi.com> Date: Tue, 9 Mar 2004 10:02:18 +0000 Subject: [PATCH] added a parameter to queueMessage git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@562 20353a03-c40f-0410-a6d1-a30d3c3de9de --- product/CMFActivity/Activity/RAMDict.py | 2 +- product/CMFActivity/Activity/RAMQueue.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/product/CMFActivity/Activity/RAMDict.py b/product/CMFActivity/Activity/RAMDict.py index 79daf3f395..a0d893dc43 100755 --- a/product/CMFActivity/Activity/RAMDict.py +++ b/product/CMFActivity/Activity/RAMDict.py @@ -44,7 +44,7 @@ class RAMDict(Queue): Queue.__init__(self) self.dict = {} - def queueMessage(self, m): + def queueMessage(self, activity_tool, m): self.dict[(m.object_path, m.method_id)] = m def dequeueMessage(self, activity_tool, processing_node): diff --git a/product/CMFActivity/Activity/RAMQueue.py b/product/CMFActivity/Activity/RAMQueue.py index 8ed6514d7a..dc3ea03948 100755 --- a/product/CMFActivity/Activity/RAMQueue.py +++ b/product/CMFActivity/Activity/RAMQueue.py @@ -38,7 +38,7 @@ class RAMQueue(Queue): Queue.__init__(self) self.queue = [] - def queueMessage(self, m): + def queueMessage(self, activity_tool, m): self.queue.append(m) def dequeueMessage(self, activity_tool, processing_node): -- 2.30.9