openstack
/
oslo.messaging
Code Issues Proposed changes

Merge "Fix clearing of the fake RPC Exchange"

This commit is contained in:
Zuul 2023-12-19 19:07:43 +00:00 committed by Gerrit Code Review
parent e2b2008ed9 f65607fa48
commit 37888462d1
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
oslo_messaging/_drivers/impl_fake.py
View File

@ -158,6 +158,10 @@ class FakeExchangeManager(object):
with self._exchanges_lock:
return self._exchanges.setdefault(name, FakeExchange(name))
@classmethod
def cleanup(cls):
cls._exchanges.clear()
class FakeDriver(base.BaseDriver):
"""Fake driver used for testing.
@ -253,4 +257,4 @@ class FakeDriver(base.BaseDriver):
batch_timeout)
def cleanup(self):
pass
self._exchange_manager.cleanup()