summaryrefslogtreecommitdiff
path: root/python/hello-world
diff options
context:
space:
mode:
authorRafael H. Schloming <rhs@apache.org>2007-08-10 15:55:16 +0000
committerRafael H. Schloming <rhs@apache.org>2007-08-10 15:55:16 +0000
commit01652ef4ec4d7a92bfdcf677c27fb28968398bc6 (patch)
tree495a8d994def30a30512beaf4077643c41cff332 /python/hello-world
parent6577b14632d81c15482cb0793e01166cdb28eaff (diff)
downloadqpid-python-01652ef4ec4d7a92bfdcf677c27fb28968398bc6.tar.gz
added support for unpacked structs and execution.result
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@564637 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/hello-world')
-rwxr-xr-xpython/hello-world12
1 files changed, 6 insertions, 6 deletions
diff --git a/python/hello-world b/python/hello-world
index 8b7a2752c5..4fb065ae53 100755
--- a/python/hello-world
+++ b/python/hello-world
@@ -3,13 +3,13 @@ import qpid
from qpid.client import Client
from qpid.content import Content
-client = Client("127.0.0.1", 5672, qpid.spec.load("../specs/amqp.0-9.xml",
- "../specs/amqp-errata.0-9.xml"))
+client = Client("127.0.0.1", 5672, qpid.spec.load("../specs/amqp.0-10-preview.xml"))
client.start({"LOGIN": "guest", "PASSWORD": "guest"})
ch = client.channel(1)
-ch.channel_open()
+ch.session_open()
ch.queue_declare(queue="test")
ch.queue_bind(exchange="amq.direct", queue="test", routing_key="test")
-ch.message_consume(queue="test", destination="test")
-ch.message_transfer(destination="amq.direct", routing_key="test",
- body="hello world")
+print ch.queue_query(queue="test")
+ch.message_subscribe(queue="test", destination="test")
+ch.message_transfer(destination="amq.direct",
+ content=Content("hello world"))