diff options
| author | Zuul <zuul@review.opendev.org> | 2022-12-20 20:12:47 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2022-12-20 20:12:47 +0000 |
| commit | bd73f14fd2b8fb7e5587888af126fc59867e4a36 (patch) | |
| tree | dfd6f1e33cda3fc1f2d275b6bdf85240d2e9f4de | |
| parent | 2e81fac97344d1eacf4c56a1022f25256d52e7ab (diff) | |
| parent | b83b87d49e9bfa8af3380c56b9910625221400a6 (diff) | |
| download | oslo-messaging-bd73f14fd2b8fb7e5587888af126fc59867e4a36.tar.gz | |
Merge "Warn when we force creating a non durable exchange"
| -rw-r--r-- | oslo_messaging/_drivers/impl_rabbit.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index 12bf82c..c61393c 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -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) |