X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fentrypoints%2Fresource_watcher.py;h=99d5595d209ba41e4354b718137b6155a8b847d6;hb=d2f6cc674bf3623caf114a8d7709e70d55ec9340;hp=98145dcfe8b1afaddbe956602e6524acdc6d74aa;hpb=c76580a35c3461254e1d8c91025019f52f723021;p=pti%2Fo2.git diff --git a/o2app/entrypoints/resource_watcher.py b/o2app/entrypoints/resource_watcher.py index 98145dc..99d5595 100644 --- a/o2app/entrypoints/resource_watcher.py +++ b/o2app/entrypoints/resource_watcher.py @@ -21,9 +21,12 @@ from o2common.service.watcher.worker import PollWorker from o2ims.service.watcher.ocloud_watcher import OcloudWatcher from o2ims.service.watcher.ocloud_watcher import DmsWatcher from o2ims.service.watcher.resourcepool_watcher import ResourcePoolWatcher +from o2ims.service.watcher.alarm_watcher import AlarmWatcher + from o2ims.adapter.clients.ocloud_client import StxDmsClient from o2ims.adapter.clients.ocloud_client import StxOcloudClient from o2ims.adapter.clients.ocloud_client import StxResourcePoolClient +from o2ims.adapter.clients.fault_client import StxAlarmClient from o2ims.service.watcher.pserver_watcher import PServerWatcher from o2ims.adapter.clients.ocloud_client import StxPserverClient @@ -62,6 +65,8 @@ class WatcherService(cotyledon.Service): StxOcloudClient(), self.bus)) root.addchild( DmsWatcher(StxDmsClient(), self.bus)) + # root.addchild( + # AlarmWatcher(StxFaultClient(), self.bus)) child_respool = root.addchild( ResourcePoolWatcher(StxResourcePoolClient(), @@ -81,6 +86,11 @@ class WatcherService(cotyledon.Service): self.worker.add_watcher(root) + # Add Alarm watch + root = WatcherTree( + AlarmWatcher(StxAlarmClient(self.bus.uow), self.bus)) + self.worker.add_watcher(root) + self.worker.start() except Exception as ex: logger.warning("WorkerService Exception:" + str(ex))