diff --git a/queue_message/appointmentrequestsender.py b/queue_message/appointmentrequestsender.py index 10533c1..8c0423c 100644 --- a/queue_message/appointmentrequestsender.py +++ b/queue_message/appointmentrequestsender.py @@ -73,6 +73,7 @@ class AppointmentRequestSender(threading.Thread): self.channel = None self.valid_csrf = None self.list_to_retrieve_mails = sub_contact_list + self.initial_contact_list = sub_contact_list self.contact_list = sub_contact_list self.queue_name = queue_name self.proxy_to_use_list = proxy_to_use_list @@ -202,7 +203,7 @@ class AppointmentRequestSender(threading.Thread): else: self.retrieve_invalidate_urls() self.logger.info("empty list") - time.sleep(120) + time.sleep(60) self.logger.info("will basic_reject method.delivery_tag: " + str(method.delivery_tag)) ch.basic_reject(delivery_tag=method.delivery_tag, requeue=True) else: @@ -229,4 +230,11 @@ class AppointmentRequestSender(threading.Thread): find_links_to_validate_from_mail_list(_mail_list_filtered) self.already_read_emails = True else: - self.logger.info("already read emails, will not retrieve validate urls") + self.logger.info("already read emails, is there any contacts to use") + self.logger.info("reset already_tried_contact_list") + self.already_tried_contact_list = [] + self.contact_list = filter_contacts(self.initial_contact_list, self.already_tried_contact_list) + self.logger.info("contact_list size is " + str(len(self.contact_list))) + if len(self.contact_list) > 0: + self.logger.info("set already_read_emails to False") + self.already_read_emails = False