We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent cdee1f8 commit 5094311Copy full SHA for 5094311
eiffellib/publishers/rabbitmq_publisher.py
@@ -132,6 +132,7 @@ def _resend_nacked_deliveries(self):
132
self._nacked_deliveries.remove(event)
133
# Never block in an ioloop method
134
self.send_event(event, block=False)
135
+ time.sleep(0.1) # Make sure we don't hog too much CPU.
136
finally:
137
self._lock.release()
138
_LOG.debug(f"[{current_thread().getName()}] '_resend_nacked_deliveries' Lock released")
0 commit comments