diff options
| -rw-r--r-- | qpid/tests/src/py/qpid_tests/broker_1_0/legacy_exchanges.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/qpid/tests/src/py/qpid_tests/broker_1_0/legacy_exchanges.py b/qpid/tests/src/py/qpid_tests/broker_1_0/legacy_exchanges.py index 024a1da689..eefa49e817 100644 --- a/qpid/tests/src/py/qpid_tests/broker_1_0/legacy_exchanges.py +++ b/qpid/tests/src/py/qpid_tests/broker_1_0/legacy_exchanges.py @@ -37,6 +37,7 @@ class LegacyExchangeTests (VersionTest): msg = rcv.fetch(0) assert msg.content == expected.content self.ssn.acknowledge(msg) + rcv.close() def test_direct(self): msgs = [Message(content=c, subject=s) for s, c in [('a', 'one'), ('b', 'two'),('a', 'three'),('b', 'four')]] |
