Test QPID echo

test_qpid.py

#!/usr/bin/python

import sys
from qpid.messaging import *

broker = sys.argv[1] + ":5672"
address = "amq.topic"

connection = Connection(broker)

try:
    connection.open()
    session = connection.session()

    sender = session.sender(address)
    receiver = session.receiver(address)

    sender.send(Message("Hello World!"))

    message = receiver.fetch()

    print message.content
    session.acknowledge()

except MessagingError, m:
    print m
finally:
    connection.close()