+def poll_and_handle_messages(mr_address, sdnr_address, sdnr_user, sdnr_pwd):
+ while True:
+ try:
+ verboseprint("Polling")
+ response = requests.get(mr_address)
+ messages = response.json()
+ for message in messages:
+ if (is_message_new_link_failure(message)):
+ handle_link_failure(message, o_ru_to_o_du_map, sdnr_address, sdnr_user, sdnr_pwd)
+ elif (is_message_clear_link_failure(message)):
+ handle_clear_link_failure(message)
+ except Exception as inst:
+ print(inst)
+
+ time.sleep(pollTime)
+
+