Commit 410244dc authored by Jean-Paul Smets's avatar Jean-Paul Smets

added _register call in activities (getRegistedMessageList)


git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@732 20353a03-c40f-0410-a6d1-a30d3c3de9de
parent 41e1d9d9
...@@ -189,6 +189,7 @@ class Queue: ...@@ -189,6 +189,7 @@ class Queue:
m.is_registered = 0 m.is_registered = 0
def getRegisteredMessageList(self, activity_buffer, activity_tool): def getRegisteredMessageList(self, activity_buffer, activity_tool):
activity_buffer._register() # This is required if flush is called without previous activate()
class_name = self.__class__.__name__ class_name = self.__class__.__name__
if hasattr(activity_buffer, '_%s_message_list' % class_name): if hasattr(activity_buffer, '_%s_message_list' % class_name):
return filter(lambda m: m.is_registered, getattr(activity_buffer, '_%s_message_list' % class_name)) return filter(lambda m: m.is_registered, getattr(activity_buffer, '_%s_message_list' % class_name))
......
...@@ -87,6 +87,7 @@ class SQLDict(RAMDict): ...@@ -87,6 +87,7 @@ class SQLDict(RAMDict):
del activity_buffer._sqldict_uid_dict[(tuple(m.object_path), m.method_id)] del activity_buffer._sqldict_uid_dict[(tuple(m.object_path), m.method_id)]
def getRegisteredMessageList(self, activity_buffer, activity_tool): def getRegisteredMessageList(self, activity_buffer, activity_tool):
activity_buffer._register() # This is required if flush is called without previous activate()
if hasattr(activity_buffer,'_sqldict_message_list'): if hasattr(activity_buffer,'_sqldict_message_list'):
return filter(lambda m: m.is_registered, activity_buffer._sqldict_message_list) return filter(lambda m: m.is_registered, activity_buffer._sqldict_message_list)
else: else:
......
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