diff options
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) |