blob: 518992409edf9041567f8c36f3acc3edd28f6811 (
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
|
#!/usr/bin/env python
import qpid
from qpid.client import Client
from qpid.content import Content
client = Client("127.0.0.1", 5672)
client.start({"LOGIN": "guest", "PASSWORD": "guest"})
ssn = client.session()
ssn.open()
ssn.queue_declare(queue="test")
ssn.queue_bind(exchange="amq.direct", queue="test", routing_key="test")
#print ssn.queue_query(queue="test")
ssn.message_subscribe(queue="test", destination="amq.direct")
ssn.message_flow("amq.direct", 0, 0xFFFFFFFF)
ssn.message_flow("amq.direct", 1, 0xFFFFFFFF)
msg = Content("hello world")
msg["content_type"] = "text/plain"
msg["routing_key"] = "test"
msg["reply_to"] = client.structs.reply_to("asdf", "fdsa")
msg["application_headers"] = {"x": 1, "y": 2, "z": "zee"}
ssn.message_transfer(destination="amq.direct", content=msg)
queue = client.queue("amq.direct")
msg = queue.get(timeout=10)
print msg
ssn.close()
|
