diff options
| author | Gordon Sim <gsim@apache.org> | 2007-07-03 15:18:03 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2007-07-03 15:18:03 +0000 |
| commit | 84856db9f9312ba65f82a129d7f2761ad80d83fc (patch) | |
| tree | 33fabe547f097e23033f810d607150c75d2a6343 /python/tests_0-9/message.py | |
| parent | 338f2196c07ea6ce2cd40941bca9ef11e95be2bf (diff) | |
| download | qpid-python-84856db9f9312ba65f82a129d7f2761ad80d83fc.tar.gz | |
Changes to python tests for QPID-533 and QPID-407.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@552872 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/tests_0-9/message.py')
| -rw-r--r-- | python/tests_0-9/message.py | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/python/tests_0-9/message.py b/python/tests_0-9/message.py index 8da9978792..b25016e680 100644 --- a/python/tests_0-9/message.py +++ b/python/tests_0-9/message.py @@ -219,10 +219,14 @@ class MessageTests(TestBase): msg4.ok() #Four channel.message_cancel(destination="consumer_tag") - channel.message_consume(queue="test-requeue", destination="consumer_tag") - queue2 = self.client.queue("consumer_tag") + #publish a new message + channel.message_transfer(routing_key="test-requeue", body="Six") + #requeue unacked messages (Three and Five) channel.message_recover(requeue=True) + + channel.message_consume(queue="test-requeue", destination="consumer_tag") + queue2 = self.client.queue("consumer_tag") msg3b = queue2.get(timeout=1) msg5b = queue2.get(timeout=1) @@ -233,6 +237,8 @@ class MessageTests(TestBase): self.assertEqual(True, msg3b.redelivered) self.assertEqual(True, msg5b.redelivered) + self.assertEqual("Six", queue2.get(timeout=1).body) + try: extra = queue2.get(timeout=1) self.fail("Got unexpected message in second queue: " + extra.body) |