RabbitMQ example in Python

receive.py

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')

def callback(ch, method, properties, body):
  print "[x] Received: %r" % (body,)

channel.basic_consume(callback, queue='hello', no_ack=True)
channel.start_consuming()

send.py

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))
channel = connection.channel()
channel.queue_declare(queue='hello')

for i in range(10000):
    body = "Hello World! (" + str(i) + ')'
    channel.basic_publish(exchange='', routing_key='hello', body=body)

print "[x] Sent! Hello Word!"
connection.close()