diff options
| author | Hervé Beraud <hberaud@redhat.com> | 2022-10-18 14:17:19 +0200 |
|---|---|---|
| committer | Hervé Beraud <hberaud@redhat.com> | 2022-10-18 14:17:19 +0200 |
| commit | b83b87d49e9bfa8af3380c56b9910625221400a6 (patch) | |
| tree | 298a6c1975b74975f82d651cabde7bcf186ab26b | |
| parent | 1fd461647f7f727dad9d4603abf0defe339d320f (diff) | |
| download | oslo-messaging-b83b87d49e9bfa8af3380c56b9910625221400a6.tar.gz | |
Warn when we force creating a non durable exchange
Adding warning logs so that users can detect the fallback with durable
exchanges.
Change-Id: Iabce0986fae6ed8838f1f94496b5994fc19cc5ef
| -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 a1f5ce2..0519ca1 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -1274,6 +1274,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) |