Author: rhs
Date: Mon Oct 12 14:34:42 2009
New Revision: 824361
URL: http://svn.apache.org/viewvc?rev=824361&view=rev
Log:
renamed ping to spout
Added:
qpid/trunk/qpid/python/examples/api/spout (contents, props changed)
- copied, changed from r824327, qpid/trunk/qpid/python/examples/api/ping
Removed:
qpid/trunk/qpid/python/examples/api/ping
Copied: qpid/trunk/qpid/python/examples/api/spout (from r824327,
qpid/trunk/qpid/python/examples/api/ping)
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/python/examples/api/spout?p2=qpid/trunk/qpid/python/examples/api/spout&p1=qpid/trunk/qpid/python/examples/api/ping&r1=824327&r2=824361&rev=824361&view=diff
==============================================================================
--- qpid/trunk/qpid/python/examples/api/ping (original)
+++ qpid/trunk/qpid/python/examples/api/spout Mon Oct 12 14:34:42 2009
@@ -51,9 +51,9 @@
url = URL(opts.broker)
if opts.id is None:
- ping_id = str(uuid4())
+ spout_id = str(uuid4())
else:
- ping_id = opts.id
+ spout_id = opts.id
if args:
addr = args.pop(0)
else:
@@ -87,7 +87,7 @@
while (opts.count == 0 or count < opts.count) and \
(opts.timeout is None or time.time() - start < opts.timeout):
msg = Message(content, reply_to=opts.reply_to)
- msg.properties["ping-id"] = "%s:%s" % (ping_id, count)
+ msg.properties["spout-id"] = "%s:%s" % (spout_id, count)
for p in opts.properties:
name, val = nameval(p)
msg.properties[name] = val
Propchange: qpid/trunk/qpid/python/examples/api/spout
------------------------------------------------------------------------------
svn:executable = *
Propchange: qpid/trunk/qpid/python/examples/api/spout
------------------------------------------------------------------------------
svn:mergeinfo =
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
