Commit 6a8ed492 authored by Sebastien Robin's avatar Sebastien Robin

added a parameter to queueMessage


git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@562 20353a03-c40f-0410-a6d1-a30d3c3de9de
parent d547eb37
...@@ -44,7 +44,7 @@ class RAMDict(Queue): ...@@ -44,7 +44,7 @@ class RAMDict(Queue):
Queue.__init__(self) Queue.__init__(self)
self.dict = {} self.dict = {}
def queueMessage(self, m): def queueMessage(self, activity_tool, m):
self.dict[(m.object_path, m.method_id)] = m self.dict[(m.object_path, m.method_id)] = m
def dequeueMessage(self, activity_tool, processing_node): def dequeueMessage(self, activity_tool, processing_node):
......
...@@ -38,7 +38,7 @@ class RAMQueue(Queue): ...@@ -38,7 +38,7 @@ class RAMQueue(Queue):
Queue.__init__(self) Queue.__init__(self)
self.queue = [] self.queue = []
def queueMessage(self, m): def queueMessage(self, activity_tool, m):
self.queue.append(m) self.queue.append(m)
def dequeueMessage(self, activity_tool, processing_node): def dequeueMessage(self, activity_tool, processing_node):
......
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