You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2009/06/02 17:38:05 UTC

svn commit: r781068 - /qpid/trunk/qpid/python/qpid/messaging.py

Author: rhs
Date: Tue Jun  2 15:38:05 2009
New Revision: 781068

URL: http://svn.apache.org/viewvc?rev=781068&view=rev
Log:
removed another turnary if

Modified:
    qpid/trunk/qpid/python/qpid/messaging.py

Modified: qpid/trunk/qpid/python/qpid/messaging.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/python/qpid/messaging.py?rev=781068&r1=781067&r2=781068&view=diff
==============================================================================
--- qpid/trunk/qpid/python/qpid/messaging.py (original)
+++ qpid/trunk/qpid/python/qpid/messaging.py Tue Jun  2 15:38:05 2009
@@ -632,7 +632,10 @@
     else:
       self._queue = "%s.%s" % (self.session.name, self.destination)
       self._ssn.queue_declare(queue=self._queue, durable=False, exclusive=True, auto_delete=True)
-      f = FILTER_DEFAULTS[result.type] if self.filter is None else self.filter
+      if self.filter is None:
+        f = FILTER_DEFAULTS[result.type]
+      else:
+        f = self.filter
       f._bind(self._ssn, self.source, self._queue)
     self._ssn.message_subscribe(queue=self._queue, destination=self.destination,
                                 sync=True)



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org