summaryrefslogtreecommitdiffstats
path: root/components/pm-subscription-handler/pmsh_service/pmsh_service_main.py
diff options
context:
space:
mode:
authorTony Hansen <tony@att.com>2021-12-07 19:37:36 +0000
committerGerrit Code Review <gerrit@onap.org>2021-12-07 19:37:36 +0000
commit10aa7f851d2256c5b158f8b4c5d3e2756890f7b7 (patch)
tree4f6de2f0a42ba5c43e1b3092426f90e3cab05e8f /components/pm-subscription-handler/pmsh_service/pmsh_service_main.py
parentb478d8b78325942550058381d3218db8c63624a6 (diff)
parent24454771f523f65fce5e3dce91cfe8cd15fc8be7 (diff)
Merge "[DCAEGEN2] PMSH Response Event Handler Integration"
Diffstat (limited to 'components/pm-subscription-handler/pmsh_service/pmsh_service_main.py')
-rwxr-xr-xcomponents/pm-subscription-handler/pmsh_service/pmsh_service_main.py3
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.')