QPID-1045 and QPID-1041: added a destination attribute to incoming queues, and added a start() method to incoming queues as syntactic sugar for the verbose message flow idiom

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@654918 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 17 insertions, 1 deletions

diff --git a/python/tests_0-10/message.py b/python/tests_0-10/message.py
index e21716d855..8f3d7bdaef 100644
--- a/python/tests_0-10/message.py
+++ b/python/tests_0-10/message.py
@@ -229,6 +229,7 @@ class MessageTests(TestBase010):
         session.message_transfer(message=Message(session.delivery_properties(routing_key="test-queue-4"), "One"))
 
         session.message_subscribe(destination="my-consumer", queue="test-queue-4")
+        myqueue = session.incoming("my-consumer")
         session.message_flow(destination="my-consumer", unit=session.credit_unit.message, value=0xFFFFFFFF)
         session.message_flow(destination="my-consumer", unit=session.credit_unit.byte, value=0xFFFFFFFF)
 
@@ -237,7 +238,6 @@ class MessageTests(TestBase010):
         #cancel should stop messages being delivered
         session.message_cancel(destination="my-consumer")
         session.message_transfer(message=Message(session.delivery_properties(routing_key="test-queue-4"), "Two"))
-        myqueue = session.incoming("my-consumer")
         msg = myqueue.get(timeout=1)
         self.assertEqual("One", msg.body)
         try:
@@ -1001,6 +1001,22 @@ class MessageTests(TestBase010):
         self.assertEquals("", msg.body)
         session.message_accept(RangedSet(msg.id))
 
+    def test_incoming_start(self):
+        q = "test_incoming_start"
+        session = self.session
+
+        session.queue_declare(queue=q, exclusive=True, auto_delete=True)
+        session.message_subscribe(queue=q, destination="msgs")
+        messages = session.incoming("msgs")
+        assert messages.destination == "msgs"
+
+        dp = session.delivery_properties(routing_key=q)
+        session.message_transfer(message=Message(dp, "test"))
+
+        messages.start()
+        msg = messages.get()
+        assert msg.body == "test"
+
     def assertDataEquals(self, session, msg, expected):
         self.assertEquals(expected, msg.body)