summaryrefslogtreecommitdiff
path: root/python/examples
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2008-06-11 21:31:12 +0000
committerRafael H. Schloming <rhs@apache.org>2008-06-11 21:31:12 +0000
commit5652a1f2c2c1ccab95086494a811e00b24a700cd (patch)
tree29dcdcaf9eb2bffb1f3f22b228d02737777a6bbe /python/examples
parent1bc8bc59f5221cb5b1607e1b5eff34ad312a77fa (diff)
downloadqpid-python-5652a1f2c2c1ccab95086494a811e00b24a700cd.tar.gz
replaced example usages of message_flow with the start() method
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@666850 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/examples')
-rwxr-xr-xpython/examples/direct/direct_consumer.py5
-rwxr-xr-xpython/examples/direct/listener.py3
-rwxr-xr-xpython/examples/fanout/fanout_consumer.py5
-rwxr-xr-xpython/examples/fanout/listener.py5
-rwxr-xr-xpython/examples/pubsub/topic_subscriber.py3
-rwxr-xr-xpython/examples/request-response/client.py3
-rwxr-xr-xpython/examples/request-response/server.py6
-rwxr-xr-xpython/examples/xml-exchange/listener.py5
-rwxr-xr-xpython/examples/xml-exchange/xml_consumer.py5
9 files changed, 15 insertions, 25 deletions
diff --git a/python/examples/direct/direct_consumer.py b/python/examples/direct/direct_consumer.py
index e421a417c1..23577e9f53 100755
--- a/python/examples/direct/direct_consumer.py
+++ b/python/examples/direct/direct_consumer.py
@@ -51,11 +51,10 @@ queue = session.incoming(local_queue_name)
# Call message_subscribe() to tell the broker to deliver messages
# from the AMQP queue to this local client queue. The broker will
# start delivering messages as soon as credit is allocated using
-# session.message_flow().
+# queue.start().
session.message_subscribe(queue="message_queue", destination=local_queue_name)
-session.message_flow(local_queue_name, session.credit_unit.message, 0xFFFFFFFF)
-session.message_flow(local_queue_name, session.credit_unit.byte, 0xFFFFFFFF)
+queue.start()
# Initialize 'final' and 'content', variables used to identify the last message.
diff --git a/python/examples/direct/listener.py b/python/examples/direct/listener.py
index 0716adecef..66927eca4b 100755
--- a/python/examples/direct/listener.py
+++ b/python/examples/direct/listener.py
@@ -74,8 +74,7 @@ queue = session.incoming(local_queue_name)
# start delivering messages as soon as message_subscribe() is called.
session.message_subscribe(queue="message_queue", destination=local_queue_name)
-session.message_flow(local_queue_name, session.credit_unit.message, 0xFFFFFFFF)
-session.message_flow(local_queue_name, session.credit_unit.byte, 0xFFFFFFFF)
+queue.start()
receiver = Receiver()
queue.listen (receiver.Handler)
diff --git a/python/examples/fanout/fanout_consumer.py b/python/examples/fanout/fanout_consumer.py
index 4a0e8ef488..a2b1b30141 100755
--- a/python/examples/fanout/fanout_consumer.py
+++ b/python/examples/fanout/fanout_consumer.py
@@ -51,12 +51,11 @@ session.exchange_bind(queue=server_queue_name, exchange="amq.fanout")
local_queue_name = "local_queue"
local_queue = session.incoming(local_queue_name)
-# Call message_consume() to tell the server to deliver messages
+# Call message_subscribe() to tell the server to deliver messages
# from the AMQP queue to this local client queue.
session.message_subscribe(queue=server_queue_name, destination=local_queue_name)
-session.message_flow(local_queue_name, session.credit_unit.message, 0xFFFFFFFF)
-session.message_flow(local_queue_name, session.credit_unit.byte, 0xFFFFFFFF)
+local_queue.start()
print "Subscribed to queue " + server_queue_name
sys.stdout.flush()
diff --git a/python/examples/fanout/listener.py b/python/examples/fanout/listener.py
index b2ed85045b..74ae858127 100755
--- a/python/examples/fanout/listener.py
+++ b/python/examples/fanout/listener.py
@@ -79,11 +79,10 @@ local_queue = session.incoming(local_queue_name)
# Call message_subscribe() to tell the broker to deliver messages
# from the AMQP queue to this local client queue. The broker will
-# start delivering messages as soon as message_subscribe() is called.
+# start delivering messages as soon as local_queue.start() is called.
session.message_subscribe(queue=server_queue_name, destination=local_queue_name)
-session.message_flow(local_queue_name, session.credit_unit.message, 0xFFFFFFFF)
-session.message_flow(local_queue_name, session.credit_unit.byte, 0xFFFFFFFF)
+local_queue.start()
receiver = Receiver ()
local_queue.listen (receiver.Handler)
diff --git a/python/examples/pubsub/topic_subscriber.py b/python/examples/pubsub/topic_subscriber.py
index 4ba8e6a680..039cc0c55b 100755
--- a/python/examples/pubsub/topic_subscriber.py
+++ b/python/examples/pubsub/topic_subscriber.py
@@ -41,8 +41,7 @@ def subscribe_queue(server_queue_name, local_queue_name):
queue = session.incoming(local_queue_name)
session.message_subscribe(queue=server_queue_name, destination=local_queue_name)
- session.message_flow(local_queue_name, session.credit_unit.message, 0xFFFFFFFF)
- session.message_flow(local_queue_name, session.credit_unit.byte, 0xFFFFFFFF)
+ queue.start()
return queue
diff --git a/python/examples/request-response/client.py b/python/examples/request-response/client.py
index 8d40aca5bb..a9ecd5c78f 100755
--- a/python/examples/request-response/client.py
+++ b/python/examples/request-response/client.py
@@ -81,8 +81,7 @@ queue = session.incoming(local_queue_name)
# available.
session.message_subscribe(queue=reply_to, destination=local_queue_name)
-session.message_flow(local_queue_name, session.credit_unit.message, 0xFFFFFFFF)
-session.message_flow(local_queue_name, session.credit_unit.byte, 0xFFFFFFFF)
+queue.start()
# Send some messages to the server's request queue
diff --git a/python/examples/request-response/server.py b/python/examples/request-response/server.py
index 99b1431509..05ee051c57 100755
--- a/python/examples/request-response/server.py
+++ b/python/examples/request-response/server.py
@@ -60,9 +60,9 @@ session.exchange_bind(exchange="amq.direct", queue="request", binding_key="reque
local_queue_name = "local_queue"
session.message_subscribe(queue="request", destination=local_queue_name)
-session.message_flow(local_queue_name, session.credit_unit.message, 0xFFFFFFFF)
-session.message_flow(local_queue_name, session.credit_unit.byte, 0xFFFFFFFF)
+queue = session.incoming(local_queue_name)
+queue.start()
# Remind the user to start the client program
@@ -72,8 +72,6 @@ sys.stdout.flush()
# Respond to each request
-queue = session.incoming(local_queue_name)
-
# If we get a message, send it back to the user (as indicated in the
# ReplyTo property)
diff --git a/python/examples/xml-exchange/listener.py b/python/examples/xml-exchange/listener.py
index db12d57e3e..dec824dddf 100755
--- a/python/examples/xml-exchange/listener.py
+++ b/python/examples/xml-exchange/listener.py
@@ -68,11 +68,10 @@ local_queue = session.incoming(local_queue_name)
# Call message_subscribe() to tell the broker to deliver messages
# from the AMQP queue to this local client queue. The broker will
-# start delivering messages as soon as message_subscribe() is called.
+# start delivering messages as soon as local_queue.start() is called.
session.message_subscribe(queue="message_queue", destination=local_queue_name)
-session.message_flow(local_queue_name, session.credit_unit.message, 0xFFFFFFFF)
-session.message_flow(local_queue_name, session.credit_unit.byte, 0xFFFFFFFF)
+local_queue.start()
receiver = Receiver ()
local_queue.listen (receiver.Handler)
diff --git a/python/examples/xml-exchange/xml_consumer.py b/python/examples/xml-exchange/xml_consumer.py
index 22973b2bd9..0ab079e7a6 100755
--- a/python/examples/xml-exchange/xml_consumer.py
+++ b/python/examples/xml-exchange/xml_consumer.py
@@ -51,11 +51,10 @@ local_queue = session.incoming(local_queue_name)
# Call message_consume() to tell the broker to deliver messages
# from the AMQP queue to this local client queue. The broker will
-# start delivering messages as soon as message_consume() is called.
+# start delivering messages as soon as local_queue.start() is called.
session.message_subscribe(queue="message_queue", destination=local_queue_name)
-session.message_flow(local_queue_name, session.credit_unit.message, 0xFFFFFFFF)
-session.message_flow(local_queue_name, session.credit_unit.byte, 0xFFFFFFFF)
+local_queue.start()
# Initialize 'final' and 'content', variables used to identify the last message.