summaryrefslogtreecommitdiff
path: root/qpid/python/hello-010-world
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2008-06-10 15:13:09 +0000
committerRafael H. Schloming <rhs@apache.org>2008-06-10 15:13:09 +0000
commit06e1426e91903056871d693aab9049f203b7b330 (patch)
tree147233cd737a790ae095367f2a23d2596d4cdd01 /qpid/python/hello-010-world
parent76ac0b8a8d74007d20cd1719086d964d8e394937 (diff)
downloadqpid-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-xqpid/python/hello-010-world53
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)