continue book

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