You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2014/09/04 22:44:46 UTC
svn commit: r1622559 - /qpid/trunk/qpid/python/qpid/messaging/driver.py
Author: aconway
Date: Thu Sep 4 20:44:46 2014
New Revision: 1622559
URL: http://svn.apache.org/r1622559
Log:
NO-JIRA: Fix qpid/python/qpid/messaging/driver.py to work on python 2.4.
Modified:
qpid/trunk/qpid/python/qpid/messaging/driver.py
Modified: qpid/trunk/qpid/python/qpid/messaging/driver.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid/messaging/driver.py?rev=1622559&r1=1622558&r2=1622559&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/messaging/driver.py (original)
+++ qpid/trunk/qpid/python/qpid/messaging/driver.py Thu Sep 4 20:44:46 2014
@@ -1052,11 +1052,12 @@ class Engine:
type = props.get("type", "queue")
declare = props.get("x-declare", {})
+ cmd = None
if type == "topic":
- cmd = ExchangeDeclare(exchange=name, durable=durable) if create_node else None
+ if create_node: cmd = ExchangeDeclare(exchange=name, durable=durable)
bindings = get_bindings(props, exchange=name)
elif type == "queue":
- cmd = QueueDeclare(queue=name, durable=durable) if create_node else None
+ if create_node: cmd = QueueDeclare(queue=name, durable=durable)
bindings = get_bindings(props, queue=name)
else:
raise ValueError(type)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org