reject message whenn the list is empty

2024-01-18 22:38:54 +01:00
parent 47cf77e049
commit 9e00b92e55
1 changed files with 3 additions and 1 deletions
@@ -95,7 +95,9 @@ class LinkValidator(threading.Thread):
            print("will ack")
            ch.basic_ack(delivery_tag=method.delivery_tag)
        else:
-            print("empty list")
+            print("empty list, no need to ack")
+            time.sleep(60)
+            ch.basic_reject(delivery_tag=method.delivery_tag, requeue=True)


 if __name__ == '__main__':