summaryrefslogtreecommitdiff
path: root/python/examples
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2008-02-08 15:01:30 +0000
committerAlan Conway <aconway@apache.org>2008-02-08 15:01:30 +0000
commit2b1f0e248873a041f7fe5bda724a0d7e13617372 (patch)
tree44d734f4c475a9eada3df0dd002e79de450e3ffa /python/examples
parent942b577d5047b3617d00a375235400e275bfe1ff (diff)
downloadqpid-python-2b1f0e248873a041f7fe5bda724a0d7e13617372.tar.gz
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
Diffstat (limited to 'python/examples')
-rwxr-xr-x[-rw-r--r--]python/examples/direct/declare_queues.py5
-rwxr-xr-x[-rw-r--r--]python/examples/direct/direct_consumer.py5
-rwxr-xr-x[-rw-r--r--]python/examples/direct/direct_producer.py5
-rwxr-xr-x[-rw-r--r--]python/examples/direct/listener.py5
-rw-r--r--python/examples/direct/verify3
-rw-r--r--python/examples/direct/verify.in14
-rwxr-xr-x[-rw-r--r--]python/examples/fanout/declare_queues.py5
-rwxr-xr-x[-rw-r--r--]python/examples/fanout/fanout_consumer.py5
-rwxr-xr-x[-rw-r--r--]python/examples/fanout/fanout_producer.py5
-rwxr-xr-x[-rw-r--r--]python/examples/fanout/listener.py5
-rw-r--r--python/examples/fanout/verify3
-rw-r--r--python/examples/fanout/verify.in14
-rwxr-xr-x[-rw-r--r--]python/examples/pubsub/topic_publisher.py6
-rwxr-xr-x[-rw-r--r--]python/examples/pubsub/topic_subscriber.py9
-rw-r--r--python/examples/pubsub/verify4
-rw-r--r--python/examples/pubsub/verify.in51
-rwxr-xr-x[-rw-r--r--]python/examples/request-response/client.py5
-rwxr-xr-x[-rw-r--r--]python/examples/request-response/server.py6
-rw-r--r--python/examples/request-response/verify5
-rw-r--r--python/examples/request-response/verify.in14
20 files changed, 147 insertions, 27 deletions
diff --git a/python/examples/direct/declare_queues.py b/python/examples/direct/declare_queues.py
index 0160f66a1d..f39f0c3349 100644..100755
--- a/python/examples/direct/declare_queues.py
+++ b/python/examples/direct/declare_queues.py
@@ -9,6 +9,7 @@
"""
import qpid
+import sys
from qpid.client import Client
from qpid.content import Content
from qpid.queue import Empty
@@ -17,8 +18,8 @@ from qpid.queue import Empty
# 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/direct/direct_consumer.py b/python/examples/direct/direct_consumer.py
index 38b1ba30a0..85c1db0a93 100644..100755
--- a/python/examples/direct/direct_consumer.py
+++ b/python/examples/direct/direct_consumer.py
@@ -7,6 +7,7 @@
"""
import qpid
+import sys
from qpid.client import Client
from qpid.content import Content
from qpid.queue import Empty
@@ -16,8 +17,8 @@ from qpid.queue import Empty
# 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/direct/direct_producer.py b/python/examples/direct/direct_producer.py
index ff662477ce..2c07bfd8e7 100644..100755
--- a/python/examples/direct/direct_producer.py
+++ b/python/examples/direct/direct_producer.py
@@ -7,6 +7,7 @@
"""
import qpid
+import sys
from qpid.client import Client
from qpid.content import Content
from qpid.queue import Empty
@@ -15,8 +16,8 @@ from qpid.queue import Empty
# 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/direct/listener.py b/python/examples/direct/listener.py
index 8324cc76a6..2dbd502fa0 100644..100755
--- a/python/examples/direct/listener.py
+++ b/python/examples/direct/listener.py
@@ -8,6 +8,7 @@
"""
import qpid
+import sys
from qpid.client import Client
from qpid.content import Content
from qpid.queue import Empty
@@ -40,8 +41,8 @@ class Receiver:
# 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/direct/verify b/python/examples/direct/verify
new file mode 100644
index 0000000000..01d81a18a1
--- /dev/null
+++ b/python/examples/direct/verify
@@ -0,0 +1,3 @@
+# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify
+clients ./declare_queues.py ./direct_producer.py ./direct_consumer.py
+outputs ./declare_queues.py.out ./direct_producer.py.out ./direct_consumer.py.out
diff --git a/python/examples/direct/verify.in b/python/examples/direct/verify.in
new file mode 100644
index 0000000000..e0dca33039
--- /dev/null
+++ b/python/examples/direct/verify.in
@@ -0,0 +1,14 @@
+==== ./declare_queues.py.out
+==== ./direct_producer.py.out
+==== ./direct_consumer.py.out
+message 0
+message 1
+message 2
+message 3
+message 4
+message 5
+message 6
+message 7
+message 8
+message 9
+That's all, folks!
diff --git a/python/examples/fanout/declare_queues.py b/python/examples/fanout/declare_queues.py
index 8840ea38e1..52f23f4f9a 100644..100755
--- a/python/examples/fanout/declare_queues.py
+++ b/python/examples/fanout/declare_queues.py
@@ -9,6 +9,7 @@
"""
import qpid
+import sys
from qpid.client import Client
from qpid.content import Content
from qpid.queue import Empty
@@ -17,8 +18,8 @@ from qpid.queue import Empty
# 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/fanout/fanout_consumer.py b/python/examples/fanout/fanout_consumer.py
index 8d852ca753..b91ea35c0d 100644..100755
--- a/python/examples/fanout/fanout_consumer.py
+++ b/python/examples/fanout/fanout_consumer.py
@@ -7,6 +7,7 @@
"""
import qpid
+import sys
from qpid.client import Client
from qpid.content import Content
from qpid.queue import Empty
@@ -16,8 +17,8 @@ from qpid.queue import Empty
# 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/fanout/fanout_producer.py b/python/examples/fanout/fanout_producer.py
index d9d8f454c8..9864c776c1 100644..100755
--- a/python/examples/fanout/fanout_producer.py
+++ b/python/examples/fanout/fanout_producer.py
@@ -7,6 +7,7 @@
"""
import qpid
+import sys
from qpid.client import Client
from qpid.content import Content
from qpid.queue import Empty
@@ -15,8 +16,8 @@ from qpid.queue import Empty
# 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/fanout/listener.py b/python/examples/fanout/listener.py
index 09dd7ddb80..8997c3698f 100644..100755
--- a/python/examples/fanout/listener.py
+++ b/python/examples/fanout/listener.py
@@ -7,6 +7,7 @@
"""
import qpid
+import sys
from qpid.client import Client
from qpid.content import Content
from qpid.queue import Empty
@@ -39,8 +40,8 @@ class Receiver:
# 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/fanout/verify b/python/examples/fanout/verify
new file mode 100644
index 0000000000..f136ccd39b
--- /dev/null
+++ b/python/examples/fanout/verify
@@ -0,0 +1,3 @@
+# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify
+clients ./declare_queues.py ./fanout_producer.py ./fanout_consumer.py
+outputs ./declare_queues.py.out ./fanout_producer.py.out ./fanout_consumer.py.out
diff --git a/python/examples/fanout/verify.in b/python/examples/fanout/verify.in
new file mode 100644
index 0000000000..c625c30773
--- /dev/null
+++ b/python/examples/fanout/verify.in
@@ -0,0 +1,14 @@
+==== ./declare_queues.py.out
+==== ./fanout_producer.py.out
+==== ./fanout_consumer.py.out
+message 0
+message 1
+message 2
+message 3
+message 4
+message 5
+message 6
+message 7
+message 8
+message 9
+That's all, folks!
diff --git a/python/examples/pubsub/topic_publisher.py b/python/examples/pubsub/topic_publisher.py
index 1ff983b315..e302d58ad4 100644..100755
--- 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
index 52ec67b77c..a5c05ba177 100644..100755
--- 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!
diff --git a/python/examples/request-response/client.py b/python/examples/request-response/client.py
index e218acce3d..6561bb6fee 100644..100755
--- a/python/examples/request-response/client.py
+++ b/python/examples/request-response/client.py
@@ -9,6 +9,7 @@
import base64
import qpid
+import sys
from qpid.client import Client
from qpid.content import Content
from qpid.queue import Empty
@@ -59,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"
diff --git a/python/examples/request-response/server.py b/python/examples/request-response/server.py
index 2730768a91..04b147d003 100644..100755
--- a/python/examples/request-response/server.py
+++ b/python/examples/request-response/server.py
@@ -6,6 +6,7 @@
"""
import qpid
+import sys
from qpid.client import Client
from qpid.content import Content
from qpid.queue import Empty
@@ -27,8 +28,8 @@ def respond(session, request):
# 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"
@@ -61,6 +62,7 @@ session.message_flow(dest, 1, 0xFFFFFFFF)
print "Request server running - run your client now."
print "(Times out after 100 seconds ...)"
+sys.stdout.flush()
# Respond to each request
diff --git a/python/examples/request-response/verify b/python/examples/request-response/verify
new file mode 100644
index 0000000000..2a2d479077
--- /dev/null
+++ b/python/examples/request-response/verify
@@ -0,0 +1,5 @@
+# See https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid/bin/verify
+background "Request server running" ./server.py
+clients ./client.py
+kill %% # Must kill the server.
+outputs "./client.py.out | remove_uuid64" " server.py.out | remove_uuid64"
diff --git a/python/examples/request-response/verify.in b/python/examples/request-response/verify.in
new file mode 100644
index 0000000000..c02a423bcb
--- /dev/null
+++ b/python/examples/request-response/verify.in
@@ -0,0 +1,14 @@
+==== ./client.py.out | remove_uuid64
+Request: Twas brilling, and the slithy toves
+Request: Did gyre and gimble in the wabe.
+Request: All mimsy were the borogroves,
+Request: And the mome raths outgrabe.
+Messages queue: ReplyTo:
+Response: TWAS BRILLING, AND THE SLITHY TOVES
+Response: DID GYRE AND GIMBLE IN THE WABE.
+Response: ALL MIMSY WERE THE BOROGROVES,
+Response: AND THE MOME RATHS OUTGRABE.
+No more messages!
+==== server.py.out | remove_uuid64
+Request server running - run your client now.
+(Times out after 100 seconds ...)