X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2common%2Fservice%2Fmessagebus.py;fp=o2common%2Fservice%2Fmessagebus.py;h=8c76ce60bdd751a4acd26bcc34bf0c5cb724f179;hb=81cd55de0440dcbc8df4d788565295d051ca91ad;hp=6c60c28918ef2c95ac70f6350cfd285c18ffbbcf;hpb=f73c8e3b01b8f5b7438ba544870e06d8f30cdea0;p=pti%2Fo2.git diff --git a/o2common/service/messagebus.py b/o2common/service/messagebus.py index 6c60c28..8c76ce6 100644 --- a/o2common/service/messagebus.py +++ b/o2common/service/messagebus.py @@ -27,6 +27,16 @@ Message = Union[commands.Command, events.Event] class MessageBus: + __instance: MessageBus = None + + @staticmethod + def set_instance(instance: MessageBus): + MessageBus.__instance = instance + + @staticmethod + def get_instance() -> MessageBus: + return MessageBus.__instance + def __init__( self, uow: unit_of_work.AbstractUnitOfWork,