X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fbootstrap.py;h=6c5b276371dd1192b739a334494cce81967b9b15;hb=refs%2Fchanges%2F82%2F7282%2F1;hp=7a074f6e7b4fabb3fe74f2ea01cce7a6c53729a2;hpb=5e02e76308e1677fb106572b885a366eb6c0fbec;p=pti%2Fo2.git diff --git a/o2app/bootstrap.py b/o2app/bootstrap.py index 7a074f6..6c5b276 100644 --- a/o2app/bootstrap.py +++ b/o2app/bootstrap.py @@ -20,8 +20,9 @@ from o2common.adapter.notifications import AbstractNotifications,\ SmoO2Notifications from o2common.adapter import redis_eventpublisher from o2common.service import unit_of_work +from o2common.service import messagebus -from o2app.service import handlers, messagebus +from o2app.service import handlers from o2app.adapter.unit_of_work import SqlAlchemyUnitOfWork from o2ims.adapter import orm as o2ims_orm @@ -71,11 +72,13 @@ def bootstrap( for command_type, handler in handlers.COMMAND_HANDLERS.items() } - return messagebus.MessageBus( + bus = messagebus.MessageBus( uow=uow, event_handlers=injected_event_handlers, command_handlers=injected_command_handlers, ) + messagebus.MessageBus.set_instance(bus) + return bus def inject_dependencies(handler, dependencies):