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 2010/02/17 18:58:23 UTC
svn commit: r911121 - /qpid/trunk/qpid/python/examples/reservations/common.py
Author: rhs
Date: Wed Feb 17 17:58:23 2010
New Revision: 911121
URL: http://svn.apache.org/viewvc?rev=911121&view=rev
Log:
removed sender caching as this should now be unnecessary
Modified:
qpid/trunk/qpid/python/examples/reservations/common.py
Modified: qpid/trunk/qpid/python/examples/reservations/common.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/python/examples/reservations/common.py?rev=911121&r1=911120&r2=911121&view=diff
==============================================================================
--- qpid/trunk/qpid/python/examples/reservations/common.py (original)
+++ qpid/trunk/qpid/python/examples/reservations/common.py Wed Feb 17 17:58:23 2010
@@ -46,7 +46,6 @@
return ()
def run(self, session):
- senders = {}
while self.running():
msg = session.next_receiver().fetch()
replies = self.dispatch(msg)
@@ -54,22 +53,17 @@
count = len(replies)
sequence = 1
for r in replies:
- if senders.has_key(r.to):
- rsnd = senders[r.to]
- else:
- rsnd = session.sender(r.to)
- senders[r.to] = rsnd
-
r.correlation_id = msg.correlation_id
r.properties["count"] = count
r.properties["sequence"] = sequence
sequence += 1
try:
- rsnd.send(r)
+ snd = session.sender(r.to)
+ snd.send(r)
except SendError, e:
print e
- del senders[r.to]
- rsnd.close()
+ finally:
+ snd.close()
session.acknowledge(msg)
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org