From 2b1f0e248873a041f7fe5bda724a0d7e13617372 Mon Sep 17 00:00:00 2001
From: Alan Conway <aconway@apache.org>
Date: Fri, 8 Feb 2008 15:01:30 +0000
Subject: Refactored verify scripts, added verify for python Examples. To
 verify an example: <qpid-trunk>/bin/verify <example-dir> See comments in
 bin/verify for more details.

Changes:
 - Each example dir has its own verify script and verify.in.
 - Added sys.stdout.flush() to som python examples so verify can tell when they're ready.
 - Made python examples svn:executable.
 - C++ examples/Makefile.am runs python examples


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@619903 13f79535-47bb-0310-9956-ffa450edef68
---
 python/examples/pubsub/topic_publisher.py  |  6 ++--
 python/examples/pubsub/topic_subscriber.py |  9 +++---
 python/examples/pubsub/verify              |  4 +++
 python/examples/pubsub/verify.in           | 51 ++++++++++++++++++++++++++++++
 4 files changed, 63 insertions(+), 7 deletions(-)
 mode change 100644 => 100755 python/examples/pubsub/topic_publisher.py
 mode change 100644 => 100755 python/examples/pubsub/topic_subscriber.py
 create mode 100644 python/examples/pubsub/verify
 create mode 100644 python/examples/pubsub/verify.in

(limited to 'python/examples/pubsub')

diff --git a/python/examples/pubsub/topic_publisher.py b/python/examples/pubsub/topic_publisher.py
old mode 100644
new mode 100755
index 1ff983b315..e302d58ad4
--- a/python/examples/pubsub/topic_publisher.py
+++ b/python/examples/pubsub/topic_publisher.py
@@ -8,6 +8,7 @@
 """
 
 import qpid
+import sys
 from qpid.client import Client
 from qpid.content import Content
 from qpid.queue import Empty
@@ -15,9 +16,8 @@ from qpid.queue import Empty
 #----- Initialization -----------------------------------
 
 #  Set parameters for login. 
-
-host="127.0.0.1"
-port=5672
+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"
diff --git a/python/examples/pubsub/topic_subscriber.py b/python/examples/pubsub/topic_subscriber.py
old mode 100644
new mode 100755
index 52ec67b77c..a5c05ba177
--- a/python/examples/pubsub/topic_subscriber.py
+++ b/python/examples/pubsub/topic_subscriber.py
@@ -7,7 +7,7 @@
 """
 
 import base64
-
+import sys
 import qpid
 from qpid.client import Client
 from qpid.content import Content
@@ -60,8 +60,8 @@ def dump_queue(client, queue_name):
 
 #  Set parameters for login
 
-host="127.0.0.1"
-port=5672
+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"
@@ -108,7 +108,8 @@ session.queue_bind(exchange="amq.topic", queue=europe, routing_key="control")
 
 # Remind the user to start the topic producer
 
-print "Queues create - please start the topic producer"
+print "Queues created - please start the topic producer"
+sys.stdout.flush()
 
 # Call dump_queue to print messages from each queue
 
diff --git a/python/examples/pubsub/verify b/python/examples/pubsub/verify
new file mode 100644
index 0000000000..bef233b4ff
--- /dev/null
+++ b/python/examples/pubsub/verify
@@ -0,0 +1,4 @@
+# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify 
+background "Queues created" ./topic_subscriber.py
+clients ./topic_publisher.py
+outputs ./topic_publisher.py.out "topic_subscriber.py.out | remove_uuid64 | sort"
diff --git a/python/examples/pubsub/verify.in b/python/examples/pubsub/verify.in
new file mode 100644
index 0000000000..19dcf88312
--- /dev/null
+++ b/python/examples/pubsub/verify.in
@@ -0,0 +1,51 @@
+==== ./topic_publisher.py.out
+==== topic_subscriber.py.out | remove_uuid64 | sort
+message 0
+message 0
+message 0
+message 0
+message 0
+message 0
+message 0
+message 0
+message 1
+message 1
+message 1
+message 1
+message 1
+message 1
+message 1
+message 1
+message 2
+message 2
+message 2
+message 2
+message 2
+message 2
+message 2
+message 2
+message 3
+message 3
+message 3
+message 3
+message 3
+message 3
+message 3
+message 3
+message 4
+message 4
+message 4
+message 4
+message 4
+message 4
+message 4
+message 4
+Messages queue: europe
+Messages queue: news
+Messages queue: usa
+Messages queue: weather
+Queues created - please start the topic producer
+That's all, folks!
+That's all, folks!
+That's all, folks!
+That's all, folks!
-- 
cgit v1.2.1