add possibility to stop at hour

queue_message/appointmentrequestsender.py

@@ -65,7 +65,7 @@ def is_open():
 class AppointmentRequestSender(threading.Thread):
     def __init__(self, sub_contact_list: list, logger, cookiesPublisher: CookiesPublisher,
                  bakeUpCookiesPublisher: CookiesPublisher,
-                 queue_name=REQUEST_DATA_QUEUE):
+                 queue_name=REQUEST_DATA_QUEUE, stop_at_hour=11, stop_at_mins=30):
         super().__init__()
         self.connection = None
         self.logger = logger
@@ -80,6 +80,8 @@ class AppointmentRequestSender(threading.Thread):
         self.queue_name = queue_name
         self.proxy_manager = ProxyManager(logger)
         self.already_read_emails = False
+        self.stop_at_hour = stop_at_hour
+        self.stop_at_mins = stop_at_mins
 
     def set_up_connection(self):
         self.connection = pika.BlockingConnection(
@@ -93,7 +95,7 @@ class AppointmentRequestSender(threading.Thread):
         self.channel.start_consuming()
 
     def on_message(self, ch, method, properties, body):
-        self.check_and_stop_if_necessary(hour_to_check=11, mins_to_check=40)
+        self.check_and_stop_if_necessary(hour_to_check=self.stop_at_hour, mins_to_check=self.stop_at_mins)
         _message_count = self.cookiesPublisher.message_count()
         self.logger.info("message count in queue is {}".format(_message_count))
         _received_object = body.decode("UTF-8")