summaryrefslogtreecommitdiff
path: root/qpid/python/examples/api/spout
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2010-02-16 03:48:44 +0000
committerRafael H. Schloming <rhs@apache.org>2010-02-16 03:48:44 +0000
commit1f0c6b6661d511d5858e3755718750a5e6fc70f8 (patch)
treed9d80581712be99836609c04e9e23398d5a6b8cd /qpid/python/examples/api/spout
parent039b5540faff26ec317b111a5c322e935ae22a45 (diff)
downloadqpid-python-1f0c6b6661d511d5858e3755718750a5e6fc70f8.tar.gz
changed sender/receiver to be synchronous by default when invoked on a connected session
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@910388 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python/examples/api/spout')
-rwxr-xr-xqpid/python/examples/api/spout12
1 files changed, 5 insertions, 7 deletions
diff --git a/qpid/python/examples/api/spout b/qpid/python/examples/api/spout
index 97cb540c21..5479b66211 100755
--- a/qpid/python/examples/api/spout
+++ b/qpid/python/examples/api/spout
@@ -113,13 +113,11 @@ try:
name, val = nameval(p)
msg.properties[name] = val
- try:
- snd.send(msg)
- count += 1
- print msg
- except SendError, e:
- print e
- break
+ snd.send(msg)
+ count += 1
+ print msg
+except SendError, e:
+ print e
except KeyboardInterrupt:
pass