rabbitmq-tutorials/python-puka/send.py
2011-07-06 13:51:53 +01:00

19 lines
413 B
Python
Executable File

#!/usr/bin/env python
import puka
client = puka.Client("amqp://localhost/")
promise = client.connect()
client.wait(promise)
promise = client.queue_declare(queue='hello')
client.wait(promise)
promise = client.basic_publish(exchange='',
routing_key='hello',
body="Hello World!")
client.wait(promise)
print " [x] Sent 'Hello World!'"
client.close()