diff --git a/nova/tests/fixtures.py b/nova/tests/fixtures.py index 73584726cf..24db14a451 100644 --- a/nova/tests/fixtures.py +++ b/nova/tests/fixtures.py @@ -788,6 +788,11 @@ class RPCFixture(fixtures.Fixture): mock_gtu.return_value = None rpc.init(CONF) + def cleanup_in_flight_rpc_messages(): + messaging._drivers.impl_fake.FakeExchangeManager._exchanges = {} + + self.addCleanup(cleanup_in_flight_rpc_messages) + class WarningsFixture(fixtures.Fixture): """Filters out warnings during test runs."""