summaryrefslogtreecommitdiff
path: root/python/tests_0-10/alternate_exchange.py
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2009-03-25 18:22:55 +0000
committerRafael H. Schloming <rhs@apache.org>2009-03-25 18:22:55 +0000
commit2d716942ffd99eb04a723ceb43709305a2eb2244 (patch)
tree3ccf86d88435ac29a06a1ea2d48469535bf7768e /python/tests_0-10/alternate_exchange.py
parentd84587631a8c6c95bc80bc7ce28dae69e07e6376 (diff)
downloadqpid-python-2d716942ffd99eb04a723ceb43709305a2eb2244.tar.gz
use longs for large hex constant literals, this avoids scary looking warnings on earlier versions of python
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@758389 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/tests_0-10/alternate_exchange.py')
-rw-r--r--python/tests_0-10/alternate_exchange.py12
1 files changed, 6 insertions, 6 deletions
diff --git a/python/tests_0-10/alternate_exchange.py b/python/tests_0-10/alternate_exchange.py
index aac8a5e15b..3b75145907 100644
--- a/python/tests_0-10/alternate_exchange.py
+++ b/python/tests_0-10/alternate_exchange.py
@@ -41,16 +41,16 @@ class AlternateExchangeTests(TestBase010):
session.queue_declare(queue="returns", exclusive=True, auto_delete=True)
session.exchange_bind(queue="returns", exchange="secondary")
session.message_subscribe(destination="a", queue="returns")
- session.message_flow(destination="a", unit=session.credit_unit.message, value=0xFFFFFFFF)
- session.message_flow(destination="a", unit=session.credit_unit.byte, value=0xFFFFFFFF)
+ session.message_flow(destination="a", unit=session.credit_unit.message, value=0xFFFFFFFFL)
+ session.message_flow(destination="a", unit=session.credit_unit.byte, value=0xFFFFFFFFL)
returned = session.incoming("a")
#declare, bind (to the primary exchange) and consume from a queue for 'processed' messages
session.queue_declare(queue="processed", exclusive=True, auto_delete=True)
session.exchange_bind(queue="processed", exchange="primary", binding_key="my-key")
session.message_subscribe(destination="b", queue="processed")
- session.message_flow(destination="b", unit=session.credit_unit.message, value=0xFFFFFFFF)
- session.message_flow(destination="b", unit=session.credit_unit.byte, value=0xFFFFFFFF)
+ session.message_flow(destination="b", unit=session.credit_unit.message, value=0xFFFFFFFFL)
+ session.message_flow(destination="b", unit=session.credit_unit.byte, value=0xFFFFFFFFL)
processed = session.incoming("b")
#publish to the primary exchange
@@ -81,8 +81,8 @@ class AlternateExchangeTests(TestBase010):
session.queue_declare(queue="deleted", exclusive=True, auto_delete=True)
session.exchange_bind(exchange="dlq", queue="deleted")
session.message_subscribe(destination="dlq", queue="deleted")
- session.message_flow(destination="dlq", unit=session.credit_unit.message, value=0xFFFFFFFF)
- session.message_flow(destination="dlq", unit=session.credit_unit.byte, value=0xFFFFFFFF)
+ session.message_flow(destination="dlq", unit=session.credit_unit.message, value=0xFFFFFFFFL)
+ session.message_flow(destination="dlq", unit=session.credit_unit.byte, value=0xFFFFFFFFL)
dlq = session.incoming("dlq")
#create a queue using the dlq as its alternate exchange: