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 2008/06/11 23:31:12 UTC
svn commit: r666850 - in /incubator/qpid/trunk/qpid/python/examples: direct/
fanout/ pubsub/ request-response/ xml-exchange/
Author: rhs
Date: Wed Jun 11 14:31:12 2008
New Revision: 666850
URL: http://svn.apache.org/viewvc?rev=666850&view=rev
Log:
replaced example usages of message_flow with the start() method
Modified:
incubator/qpid/trunk/qpid/python/examples/direct/direct_consumer.py
incubator/qpid/trunk/qpid/python/examples/direct/listener.py
incubator/qpid/trunk/qpid/python/examples/fanout/fanout_consumer.py
incubator/qpid/trunk/qpid/python/examples/fanout/listener.py
incubator/qpid/trunk/qpid/python/examples/pubsub/topic_subscriber.py
incubator/qpid/trunk/qpid/python/examples/request-response/client.py
incubator/qpid/trunk/qpid/python/examples/request-response/server.py
incubator/qpid/trunk/qpid/python/examples/xml-exchange/listener.py
incubator/qpid/trunk/qpid/python/examples/xml-exchange/xml_consumer.py
Modified: incubator/qpid/trunk/qpid/python/examples/direct/direct_consumer.py
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/examples/direct/direct_consumer.py?rev=666850&r1=666849&r2=666850&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/examples/direct/direct_consumer.py (original)
+++ incubator/qpid/trunk/qpid/python/examples/direct/direct_consumer.py Wed Jun 11 14:31:12 2008
@@ -51,11 +51,10 @@
# 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.
Modified: incubator/qpid/trunk/qpid/python/examples/direct/listener.py
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/examples/direct/listener.py?rev=666850&r1=666849&r2=666850&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/examples/direct/listener.py (original)
+++ incubator/qpid/trunk/qpid/python/examples/direct/listener.py Wed Jun 11 14:31:12 2008
@@ -74,8 +74,7 @@
# 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)
Modified: incubator/qpid/trunk/qpid/python/examples/fanout/fanout_consumer.py
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/examples/fanout/fanout_consumer.py?rev=666850&r1=666849&r2=666850&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/examples/fanout/fanout_consumer.py (original)
+++ incubator/qpid/trunk/qpid/python/examples/fanout/fanout_consumer.py Wed Jun 11 14:31:12 2008
@@ -51,12 +51,11 @@
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()
Modified: incubator/qpid/trunk/qpid/python/examples/fanout/listener.py
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/examples/fanout/listener.py?rev=666850&r1=666849&r2=666850&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/examples/fanout/listener.py (original)
+++ incubator/qpid/trunk/qpid/python/examples/fanout/listener.py Wed Jun 11 14:31:12 2008
@@ -79,11 +79,10 @@
# 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)
Modified: incubator/qpid/trunk/qpid/python/examples/pubsub/topic_subscriber.py
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/examples/pubsub/topic_subscriber.py?rev=666850&r1=666849&r2=666850&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/examples/pubsub/topic_subscriber.py (original)
+++ incubator/qpid/trunk/qpid/python/examples/pubsub/topic_subscriber.py Wed Jun 11 14:31:12 2008
@@ -41,8 +41,7 @@
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
Modified: incubator/qpid/trunk/qpid/python/examples/request-response/client.py
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/examples/request-response/client.py?rev=666850&r1=666849&r2=666850&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/examples/request-response/client.py (original)
+++ incubator/qpid/trunk/qpid/python/examples/request-response/client.py Wed Jun 11 14:31:12 2008
@@ -81,8 +81,7 @@
# 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
Modified: incubator/qpid/trunk/qpid/python/examples/request-response/server.py
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/examples/request-response/server.py?rev=666850&r1=666849&r2=666850&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/examples/request-response/server.py (original)
+++ incubator/qpid/trunk/qpid/python/examples/request-response/server.py Wed Jun 11 14:31:12 2008
@@ -60,9 +60,9 @@
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 @@
# 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)
Modified: incubator/qpid/trunk/qpid/python/examples/xml-exchange/listener.py
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/examples/xml-exchange/listener.py?rev=666850&r1=666849&r2=666850&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/examples/xml-exchange/listener.py (original)
+++ incubator/qpid/trunk/qpid/python/examples/xml-exchange/listener.py Wed Jun 11 14:31:12 2008
@@ -68,11 +68,10 @@
# 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)
Modified: incubator/qpid/trunk/qpid/python/examples/xml-exchange/xml_consumer.py
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/python/examples/xml-exchange/xml_consumer.py?rev=666850&r1=666849&r2=666850&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/python/examples/xml-exchange/xml_consumer.py (original)
+++ incubator/qpid/trunk/qpid/python/examples/xml-exchange/xml_consumer.py Wed Jun 11 14:31:12 2008
@@ -51,11 +51,10 @@
# 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.