Code Review
/
pti
/
o2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Adjust API level on swagger and set API doc expansion by default
[pti/o2.git]
/
o2ims
/
service
/
messagebus.py
diff --git
a/o2ims/service/messagebus.py
b/o2ims/service/messagebus.py
index
c1970f8
..
297aa8f
100644
(file)
--- a/
o2ims/service/messagebus.py
+++ b/
o2ims/service/messagebus.py
@@
-41,7
+41,9
@@
class MessageBus:
self.queue = [message]
while self.queue:
message = self.queue.pop(0)
self.queue = [message]
while self.queue:
message = self.queue.pop(0)
- if isinstance(message, events.Event):
+ if not message:
+ continue
+ elif isinstance(message, events.Event):
self.handle_event(message)
elif isinstance(message, commands.Command):
self.handle_command(message)
self.handle_event(message)
elif isinstance(message, commands.Command):
self.handle_command(message)
@@
-65,6
+67,6
@@
class MessageBus:
handler = self.command_handlers[type(command)]
handler(command)
self.queue.extend(self.uow.collect_new_events())
handler = self.command_handlers[type(command)]
handler(command)
self.queue.extend(self.uow.collect_new_events())
- except Exception:
+ except Exception
as ex
:
logger.exception("Exception handling command %s", command)
logger.exception("Exception handling command %s", command)
- raise
+ raise
ex