diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2008-06-10 15:13:09 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2008-06-10 15:13:09 +0000 |
| commit | 2f81249d0effa7cfe9ba5bdc1033565282292399 (patch) | |
| tree | 0a972486f3f1b3eaa6acd3aba7dca2a60442a24d /python/hello-010-world | |
| parent | 83ab3794444685c5f0e0f659da2ead70d396817d (diff) | |
| download | qpid-python-2f81249d0effa7cfe9ba5bdc1033565282292399.tar.gz | |
updated the hello-world script
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@666146 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/hello-010-world')
| -rwxr-xr-x | python/hello-010-world | 53 |
1 files changed, 0 insertions, 53 deletions
diff --git a/python/hello-010-world b/python/hello-010-world deleted file mode 100755 index a15817cd9d..0000000000 --- a/python/hello-010-world +++ /dev/null @@ -1,53 +0,0 @@ -#!/usr/bin/env python - -import sys -from qpid.connection010 import Connection -from qpid.spec010 import load -from qpid.util import connect -from qpid.datatypes import Message, RangedSet -from qpid.log import enable, DEBUG, WARN - -if "-v" in sys.argv: - level = DEBUG -else: - level = WARN - -enable("qpid.io.ctl", level) -enable("qpid.io.cmd", level) - -spec = load("../specs/amqp.0-10.xml") -conn = Connection(connect("0.0.0.0", spec.port), spec) -conn.start(timeout=10) - -ssn = conn.session("my-session", timeout=10) - -ssn.queue_declare("asdf") - - -ssn.message_transfer("this", None, None, Message("testing...")) -props = ssn.delivery_properties(routing_key="asdf") -ssn.message_transfer("is", None, None, Message(props, "more testing...")) -ssn.message_transfer("a") -ssn.message_transfer("test") - -m1 = ssn.incoming("this").get(timeout=10) -print m1 -m2 = ssn.incoming("is").get(timeout=10) -print m2 -m3 = ssn.incoming("a").get(timeout=10) -print m3 -m4 = ssn.incoming("test").get(timeout=10) -print m4 - -print ssn.sender._completed, ssn.sender.next_id -ssn.sync(10) -print ssn.sender.segments - -ssn.channel.session_flush(completed=True) - -ssn.message_accept(RangedSet(m1.id, m2.id, m3.id, m4.id)) - -print ssn.queue_query("testing") - -ssn.close(timeout=10) -conn.close(timeout=10) |
