panleicim/appointment_request
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add possibility to stop at hour

Browse Source
This commit is contained in:
PAN Lei
2024-07-31 04:23:31 +02:00
parent 0663c876de
commit 692afc3a39
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
queue_message/appointmentrequestsender.py
+11
View File
@@ -93,6 +93,7 @@ class AppointmentRequestSender(threading.Thread):
self.channel.start_consuming() self.channel.start_consuming()
def on_message(self, ch, method, properties, body): def on_message(self, ch, method, properties, body):
self.check_and_stop_if_necessary(hour_to_check=11, mins_to_check=40)
_message_count = self.cookiesPublisher.message_count() _message_count = self.cookiesPublisher.message_count()
self.logger.info("message count in queue is {}".format(_message_count)) self.logger.info("message count in queue is {}".format(_message_count))
_received_object = body.decode("UTF-8") _received_object = body.decode("UTF-8")
@@ -261,3 +262,13 @@ class AppointmentRequestSender(threading.Thread):
else: else:
self.logger.info("already read emails, no contact to use -> stop") self.logger.info("already read emails, no contact to use -> stop")
self.channel.stop_consuming() self.channel.stop_consuming()
def check_and_stop_if_necessary(self, hour_to_check, mins_to_check):
hour = datetime.datetime.now().hour
mins = datetime.datetime.now().minute
if hour == hour_to_check and mins >= mins_to_check:
self.logger.info("will stop")
self.channel.stop_consuming()
elif hour > hour_to_check:
self.logger.info("will stop")
self.channel.stop_consuming()