def _retry(self, f):
while True:
try:
return f()
except pika.exceptions.ConnectionClosed:
logging.exception("AMQP connection is down...")
time.sleep(1)
self._connect()