Commit 35f80352 authored by Jean-Paul Smets's avatar Jean-Paul Smets

back to previous getRegisteredMessageList


git-svn-id: https://svn.erp5.org/repos/public/erp5/trunk@733 20353a03-c40f-0410-a6d1-a30d3c3de9de
parent 410244dc
...@@ -189,7 +189,6 @@ class Queue: ...@@ -189,7 +189,6 @@ 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,7 +87,6 @@ class SQLDict(RAMDict): ...@@ -87,7 +87,6 @@ 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