From b66e35a493f8674cae39568bf876c0f76da6324a Mon Sep 17 00:00:00 2001 From: Tobias Persson Date: Wed, 23 Feb 2022 09:58:07 +0100 Subject: [PATCH] Add a sleep to re-sending nacked events --- eiffellib/publishers/rabbitmq_publisher.py | 1 + 1 file changed, 1 insertion(+) diff --git a/eiffellib/publishers/rabbitmq_publisher.py b/eiffellib/publishers/rabbitmq_publisher.py index bfa0775..97d0a14 100644 --- a/eiffellib/publishers/rabbitmq_publisher.py +++ b/eiffellib/publishers/rabbitmq_publisher.py @@ -132,6 +132,7 @@ def _resend_nacked_deliveries(self): self._nacked_deliveries.remove(event) # Never block in an ioloop method self.send_event(event, block=False) + time.sleep(0.1) # Make sure we don't hog too much CPU. finally: self._lock.release() _LOG.debug(f"[{current_thread().getName()}] '_resend_nacked_deliveries' Lock released")