blob: 91ebc242c69d36e30480abe7ba42d17539a0938c (
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
28
|
#!/usr/bin/env python
import logging
from qpid.connection010 import Connection
from qpid.spec010 import load
from qpid.util import connect
from qpid.datatypes import Message
format = "%(asctime)s %(name)-12s %(levelname)-8s %(message)s"
logging.basicConfig(level=logging.DEBUG, format=format, datefmt='%H:%M:%S')
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")
ssn.queue_declare("asdf")
ssn.message_transfer("this", None, None, Message("testing..."))
ssn.message_transfer("is")
ssn.message_transfer("a")
ssn.message_transfer("test")
print ssn.queue_query("testing")
ssn.close(timeout=10)
conn.close(timeout=10)
|
