diff options
Diffstat (limited to 'qpid/python/examples/fanout/fanout_producer.py')
| -rwxr-xr-x | qpid/python/examples/fanout/fanout_producer.py | 32 |
1 files changed, 17 insertions, 15 deletions
diff --git a/qpid/python/examples/fanout/fanout_producer.py b/qpid/python/examples/fanout/fanout_producer.py index 9864c776c1..1b5ea6995e 100755 --- a/qpid/python/examples/fanout/fanout_producer.py +++ b/qpid/python/examples/fanout/fanout_producer.py @@ -5,11 +5,13 @@ Publishes messages to an AMQP direct exchange, using the routing key "routing_key" """ - import qpid import sys -from qpid.client import Client -from qpid.content import Content +import os +from random import randint +from qpid.util import connect +from qpid.connection import Connection +from qpid.datatypes import Message from qpid.queue import Empty #----- Initialization ----------------------------------- @@ -18,32 +20,32 @@ from qpid.queue import Empty host=len(sys.argv) > 1 and sys.argv[1] or "127.0.0.1" port=len(sys.argv) > 2 and int(sys.argv[2]) or 5672 -amqp_spec="/usr/share/amqp/amqp.0-10-preview.xml" user="guest" password="guest" +amqp_spec="" -# Create a client and log in to it. +try: + amqp_spec = os.environ["AMQP_SPEC"] +except KeyError: + amqp_spec="/usr/share/amqp/amqp.0-10.xml" -client = Client(host, port, qpid.spec.load(amqp_spec)) -client.start({"LOGIN": user, "PASSWORD": password}) +# Create a connection. +conn = Connection (connect (host,port), qpid.spec.load(amqp_spec)) +conn.start() -session = client.session() -session.session_open() +session = conn.session(str(randint(1,64*1024))) #----- Publish some messages ------------------------------ # Create some messages and put them on the broker. for i in range(10): - message = Content(body="message " + str(i)) - session.message_transfer(destination="amq.fanout", content=message) + session.message_transfer("amq.fanout", None, None ,Message("message " + str(i))) -final="That's all, folks!" -message=Content(final) -session.message_transfer(destination="amq.fanout", content=message) +session.message_transfer("amq.fanout", None, None, Message("That's all, folks!")) #----- Cleanup -------------------------------------------- # Clean up before exiting so there are no open threads. -session.session_close() +session.close(timeout=10) |
