You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by tr...@apache.org on 2013/09/06 16:49:01 UTC
svn commit: r1520587 -
/qpid/trunk/qpid/extras/dispatch/tests/system_tests_one_router.py
Author: tross
Date: Fri Sep 6 14:49:00 2013
New Revision: 1520587
URL: http://svn.apache.org/r1520587
Log:
NO-JIRA - Added a new test for tracked-and-undeliverable messages.
Modified:
qpid/trunk/qpid/extras/dispatch/tests/system_tests_one_router.py
Modified: qpid/trunk/qpid/extras/dispatch/tests/system_tests_one_router.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/extras/dispatch/tests/system_tests_one_router.py?rev=1520587&r1=1520586&r2=1520587&view=diff
==============================================================================
--- qpid/trunk/qpid/extras/dispatch/tests/system_tests_one_router.py (original)
+++ qpid/trunk/qpid/extras/dispatch/tests/system_tests_one_router.py Fri Sep 6 14:49:00 2013
@@ -45,6 +45,7 @@ class RouterTest(unittest.TestCase):
messenger.subscribe(address)
self.flush(messenger)
+
def test_0_discard(self):
addr = "amqp://0.0.0.0:20000/discard/1"
M1 = Messenger()
@@ -58,6 +59,7 @@ class RouterTest(unittest.TestCase):
M1.send()
M1.stop()
+
def test_1_pre_settled(self):
addr = "amqp://0.0.0.0:20000/pre_settled/1"
M1 = Messenger()
@@ -196,8 +198,25 @@ class RouterTest(unittest.TestCase):
M2.stop()
-# def test_4_unsettled_undeliverable(self):
-# pass
+ def test_4_unsettled_undeliverable(self):
+ addr = "amqp://0.0.0.0:20000/unsettled_undeliverable/1"
+ M1 = Messenger()
+
+ M1.timeout = 1.0
+ M1.outgoing_window = 5
+
+ M1.start()
+ tm = Message()
+ tm.address = addr
+ tm.body = {'number': 200}
+
+ tx_tracker = M1.put(tm)
+ M1.send(0)
+ self.flush(M1)
+ self.assertEqual(PENDING, M1.status(tx_tracker)) ## Is this right???
+
+ M1.stop()
+
def test_5_three_ack(self):
addr = "amqp://0.0.0.0:20000/three_ack/1"
@@ -259,8 +278,8 @@ class RouterTest(unittest.TestCase):
# pass
- def test_8_trace(self):
- addr = "amqp://0.0.0.0:20000/trace/1"
+ def test_8_delivery_annotations(self):
+ addr = "amqp://0.0.0.0:20000/da/1"
M1 = Messenger()
M2 = Messenger()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org