From 7d890288c04e114499ebf5fd236d4afe12e23a78 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Thu, 24 Jun 2010 11:22:28 +0000 Subject: QPID-2691: ensure ttl adjustment uses correct expiration on cloned message git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@957511 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/federation.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'cpp/src/tests') diff --git a/cpp/src/tests/federation.py b/cpp/src/tests/federation.py index d7f93420e9..63e3f2ba19 100755 --- a/cpp/src/tests/federation.py +++ b/cpp/src/tests/federation.py @@ -358,7 +358,7 @@ class FederationTests(TestBase010): for b, t in zip(body, trace): headers = {} if (t): headers["x-qpid.trace"]=t - dp = r_session.delivery_properties(routing_key="my-key") + dp = r_session.delivery_properties(routing_key="my-key", ttl=1000*60*5) mp = r_session.message_properties(application_headers=headers) r_session.message_transfer(destination="amq.direct", message=Message(dp, mp, b)) @@ -366,6 +366,8 @@ class FederationTests(TestBase010): msg = queue.get(timeout=5) self.assertEqual("yes", msg.body) self.assertEqual(e, self.getAppHeader(msg, "x-qpid.trace")) + assert(msg.get("delivery_properties").ttl > 0) + assert(msg.get("delivery_properties").ttl < 1000*60*50) try: extra = queue.get(timeout=1) -- cgit v1.2.1