blob: 5ba14b0fc1afd13ae6f3b356d1ea139cd3151cc6 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
#!/usr/bin/env python
import qpid
from qpid.client import Client
from qpid.content import Content
spec = qpid.spec.load("../specs/amqp.0-10-preview.xml")
client = Client("127.0.0.1", 5672, spec)
client.start({"LOGIN": "guest", "PASSWORD": "guest"})
ch = client.channel(1)
ch.session_open()
ch.queue_declare(queue="test")
ch.queue_bind(exchange="amq.direct", queue="test", routing_key="test")
#print ch.queue_query(queue="test")
ch.message_subscribe(queue="test", destination="amq.direct")
ch.message_flow("amq.direct", 0, 0xFFFFFFFF)
ch.message_flow("amq.direct", 1, 0xFFFFFFFF)
msg = Content("hello world")
msg["content_type"] = "text/plain"
msg["routing_key"] = "test"
msg["reply_to"] = spec.struct("reply_to")
msg["reply_to"].exchange_name = "asdf"
msg["reply_to"].routing_key = "fdsa"
msg["application_headers"] = {"x": 1, "y": 2, "z": "zee"}
ch.message_transfer(destination="amq.direct", content=msg)
queue = client.queue("amq.direct")
msg = queue.get(timeout=10)
print msg
|
