diff options
Diffstat (limited to 'policyhandler/policy_receiver.py')
| -rw-r--r-- | policyhandler/policy_receiver.py | 15 |
1 files changed, 10 insertions, 5 deletions
diff --git a/policyhandler/policy_receiver.py b/policyhandler/policy_receiver.py index d949c4b..091c2c3 100644 --- a/policyhandler/policy_receiver.py +++ b/policyhandler/policy_receiver.py @@ -1,5 +1,5 @@ # ================================================================================ -# Copyright (c) 2018-2019 AT&T Intellectual Property. All rights reserved. +# Copyright (c) 2018-2020 AT&T Intellectual Property. All rights reserved. # ================================================================================ # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. @@ -24,13 +24,15 @@ on receiving the policy-notifications, the policy-receiver passes the notifications to policy-updater """ +from .config import Config from .service_activator import ServiceActivator + class PolicyReceiver(object): """ policy-receiver - static singleton wrapper around two threads policy_updater - master thread for all scheduled actions - policy_listener - listens to policy-engine through web-socket + policy_listener - listens to policy-engine through DMaaP MR or web-socket """ _policy_updater = None _policy_listener = None @@ -47,9 +49,9 @@ class PolicyReceiver(object): def _close_listener(audit): """stop the notification-handler""" if PolicyReceiver._policy_listener: - policy_receiver = PolicyReceiver._policy_listener + policy_listener = PolicyReceiver._policy_listener PolicyReceiver._policy_listener = None - policy_receiver.shutdown(audit) + policy_listener.shutdown(audit) @staticmethod def shutdown(audit): @@ -98,4 +100,7 @@ class PolicyReceiver(object): PolicyReceiver._policy_updater.start() - PolicyReceiver.catch_up(audit) + if Config.is_pdp_api_default(): + audit.audit_done(result="will catch_up after draining the policy-update queue") + else: + PolicyReceiver.catch_up(audit) |