diff options
author | 2021-12-07 19:37:36 +0000 | |
---|---|---|
committer | 2021-12-07 19:37:36 +0000 | |
commit | 10aa7f851d2256c5b158f8b4c5d3e2756890f7b7 (patch) | |
tree | 4f6de2f0a42ba5c43e1b3092426f90e3cab05e8f /components/pm-subscription-handler/pmsh_service/pmsh_service_main.py | |
parent | b478d8b78325942550058381d3218db8c63624a6 (diff) | |
parent | 24454771f523f65fce5e3dce91cfe8cd15fc8be7 (diff) |
Merge "[DCAEGEN2] PMSH Response Event Handler Integration"
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 | 3 |
1 files changed, 1 insertions, 2 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 0b6544b5..fe151c0d 100755 --- a/components/pm-subscription-handler/pmsh_service/pmsh_service_main.py +++ b/components/pm-subscription-handler/pmsh_service/pmsh_service_main.py @@ -35,13 +35,12 @@ def main(): app_conf = AppConfig() pmsh_app_conf = NewAppConfig() policy_mr_pub = app_conf.get_mr_pub('policy_pm_publisher') - policy_mr_sub = app_conf.get_mr_sub('policy_pm_subscriber') aai_event_mr_sub = app_conf.get_mr_sub('aai_subscriber') except Exception as e: logger.error(f'Failed to get config and create application: {e}', exc_info=True) sys.exit(e) - policy_response_handler = PolicyResponseHandler(policy_mr_sub, app_conf, app) + policy_response_handler = PolicyResponseHandler(app) policy_response_handler_thread = PeriodicTask(25, policy_response_handler.poll_policy_topic) policy_response_handler_thread.name = 'policy_event_thread' logger.info('Start polling PMSH_CL_INPUT topic on DMaaP MR.') |