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 | 06e1426e91903056871d693aab9049f203b7b330 (patch) | |
| tree | 147233cd737a790ae095367f2a23d2596d4cdd01 /qpid/python/hello-010-world | |
| parent | 76ac0b8a8d74007d20cd1719086d964d8e394937 (diff) | |
| download | qpid-python-06e1426e91903056871d693aab9049f203b7b330.tar.gz | |
updated the hello-world script
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@666146 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/python/hello-010-world')
| -rwxr-xr-x | qpid/python/hello-010-world | 53 |
1 files changed, 0 insertions, 53 deletions
diff --git a/qpid/python/hello-010-world b/qpid/python/hello-010-world deleted file mode 100755 index a15817cd9d..0000000000 --- a/qpid/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) |
