From f6f5a3deb6dfe337081d58bcb6d97ec4f03e6531 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@957511 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/tests/federation.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'qpid/cpp/src/tests') diff --git a/qpid/cpp/src/tests/federation.py b/qpid/cpp/src/tests/federation.py index d7f93420e9..63e3f2ba19 100755 --- a/qpid/cpp/src/tests/federation.py +++ b/qpid/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