X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2common%2Fservice%2Fmessagebus.py;h=8c76ce60bdd751a4acd26bcc34bf0c5cb724f179;hb=cd999dd33a2449fd8480fd641678360a749e5498;hp=6c60c28918ef2c95ac70f6350cfd285c18ffbbcf;hpb=84867b76a65efc4e9add52c86eae7e451c4a038d;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,