Merge "Warn when we force creating a non durable exchange"

This commit is contained in:
Zuul 2022-12-20 20:12:47 +00:00 committed by Gerrit Code Review
commit bd73f14fd2
1 changed files with 1 additions and 0 deletions

View File

@ -1409,6 +1409,7 @@ class Connection(object):
# from the one used first.
if "PRECONDITION_FAILED - inequivalent arg 'durable'" \
in str(err):
LOG.warning("Force creating a non durable exchange.")
exchange.durable = False
exchange(self.channel).declare()
self._declared_exchanges.add(exchange.name)