diff options
author | 2020-04-21 13:39:35 +0100 | |
---|---|---|
committer | 2020-04-22 14:41:17 +0100 | |
commit | ae21e35b8eb8008cf1a3119bab2ad987db9f9e7f (patch) | |
tree | 22769a4a52169095f37f0ed4377355771d7910ad /components/pm-subscription-handler/pmsh_service/pmsh_service_main.py | |
parent | 8c68d73eb231da211abe962478c1c77d49665874 (diff) |
[PMSH] Adding cbs module support
Signed-off-by: efiacor <fiachra.corcoran@est.tech>
Change-Id: Ie711995a3c7a2111f6cb872952507f511c0de6dd
Issue-ID: DCAEGEN2-2156
Diffstat (limited to 'components/pm-subscription-handler/pmsh_service/pmsh_service_main.py')
-rwxr-xr-x | components/pm-subscription-handler/pmsh_service/pmsh_service_main.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/components/pm-subscription-handler/pmsh_service/pmsh_service_main.py b/components/pm-subscription-handler/pmsh_service/pmsh_service_main.py index 60cf89c0..a2ba1fd3 100755 --- a/components/pm-subscription-handler/pmsh_service/pmsh_service_main.py +++ b/components/pm-subscription-handler/pmsh_service/pmsh_service_main.py @@ -23,9 +23,8 @@ import mod.aai_client as aai import mod.pmsh_logging as logger from mod import db, create_app, launch_api_server from mod.aai_event_handler import process_aai_events -from mod.config_handler import ConfigHandler from mod.exit_handler import ExitHandler -from mod.pmsh_utils import AppConfig, PeriodicTask +from mod.pmsh_utils import AppConfig, PeriodicTask, ConfigHandler from mod.policy_response_handler import PolicyResponseHandler from mod.subscription import Subscription, AdministrativeState from mod.subscription_handler import SubscriptionHandler @@ -33,12 +32,13 @@ from mod.subscription_handler import SubscriptionHandler def main(): try: - config_handler = ConfigHandler() - config = config_handler.get_config() - app_conf = AppConfig(**config['config']) app = create_app() app.app_context().push() db.create_all(app=app) + + config = ConfigHandler.get_pmsh_config() + app_conf = AppConfig(**config['config']) + sub, nfs = aai.get_pmsh_subscription_data(config) policy_mr_pub = app_conf.get_mr_pub('policy_pm_publisher') policy_mr_sub = app_conf.get_mr_sub('policy_pm_subscriber') @@ -50,7 +50,7 @@ def main(): aai_event_thread = PeriodicTask(10, process_aai_events, args=(mr_aai_event_sub, sub, policy_mr_pub, app, app_conf)) - subscription_handler = SubscriptionHandler(config_handler, administrative_state, + subscription_handler = SubscriptionHandler(administrative_state, policy_mr_pub, app, app_conf, aai_event_thread) policy_response_handler = PolicyResponseHandler(policy_mr_sub, sub.subscriptionName, app) |