Commit 4ed4cc68 authored by Carlos Ramos Carreño's avatar Carlos Ramos Carreño

Fixes the error in `test_onErrorCallback`.

See merge request nexedi/erp5!1935
parents c497f144 94a22885
...@@ -83,7 +83,8 @@ def sort_message_key(message): ...@@ -83,7 +83,8 @@ def sort_message_key(message):
# same sort key as in SQLBase.getMessageList # same sort key as in SQLBase.getMessageList
return message.line.priority, message.line.date, message.uid return message.line.priority, message.line.date, message.uid
_DequeueMessageException = Exception() class _DequeueMessageException(Exception):
pass
_ITEMGETTER0 = operator.itemgetter(0) _ITEMGETTER0 = operator.itemgetter(0)
_IDENTITY = lambda x: x _IDENTITY = lambda x: x
...@@ -1009,11 +1010,11 @@ CREATE TABLE %s ( ...@@ -1009,11 +1010,11 @@ CREATE TABLE %s (
# increased. # increased.
for m in message_list: for m in message_list:
if m.getExecutionState() == MESSAGE_NOT_EXECUTED: if m.getExecutionState() == MESSAGE_NOT_EXECUTED:
raise _DequeueMessageException raise _DequeueMessageException()
transaction.commit() transaction.commit()
except: except:
exc_info = sys.exc_info() exc_info = sys.exc_info()
if exc_info[1] is not _DequeueMessageException: if not isinstance(exc_info[1], _DequeueMessageException):
self._log(WARNING, self._log(WARNING,
'Exception raised when invoking messages (uid, path, method_id) %r' 'Exception raised when invoking messages (uid, path, method_id) %r'
% [(m.uid, m.object_path, m.method_id) for m in message_list]) % [(m.uid, m.object_path, m.method_id) for m in message_list])
......
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