rabbitmq python

cyrus

　　import pika
　　connection = pika.BlockingConnection(pika.ConnectionParameters(
　　'localhost',9672))
　　channel = connection.channel()
　　channel.queue_declare(queue='hello')
　　channel.basic_publish(exchange='',
　　routing_key='hello',
　　body='Hello World!')
　　print " [x] Sent 'Hello World!'"
　　connection.close()
　　$ sudo rabbitmqctl list_queues
　　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)
　　print '

Waiting for messages. To exit press CTRL+C'
　　channel.start_consuming()
　　send.py:
!/usr/bin/env python
　　import pika
　　connection = pika.BlockingConnection(pika.ConnectionParameters(
　　host='localhost'))
　　channel = connection.channel()
　　channel.queue_declare(queue='hello')
　　channel.basic_publish(exchange='',
　　routing_key='hello',
　　body='Hello World!')
　　print " [x] Sent 'Hello World!'"
　　connection.close()
　　receive.py:
!/usr/bin/env python
　　import pika
　　connection = pika.BlockingConnection(pika.ConnectionParameters(
　　host='localhost'))
　　channel = connection.channel()
　　channel.queue_declare(queue='hello')
　　print '

Waiting for messages. To exit press CTRL+C'
　　def callback(ch, method, properties, body):
　　print " [x] Received %r" % (body,)
　　channel.basic_consume(callback,
　　queue='hello',
　　no_ack=True)
　　channel.start_consuming()