diff options
Diffstat (limited to 'qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py')
| -rw-r--r-- | qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py b/qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py index 05c4815e57..18a13e3ddf 100644 --- a/qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py +++ b/qpid/tests/src/py/qpid_tests/broker_0_10/new_api.py @@ -106,10 +106,10 @@ class GeneralTests(Base): self.assertEqual(rx_alt.available(), 0, "No messages should have been routed to the alt_exchange") - # Close sess1; This will cause the queue to be deleted + # Close sess1; This will cause the queue to be deleted and all its messages (including those acquired) to be reouted to the alternate exchange sess1.close() sleep(1) - self.assertEqual(rx_alt.available(), 2, "2 of the messages should have been routed to the alt_exchange") + self.assertEqual(rx_alt.available(), 5, "All the messages should have been routed to the alt_exchange") # Close sess2; This will cause the acquired messages to be requeued and routed to the alternate sess2.close() |