producer.py

# example_publisher.py
import pika, os, logging
logging.basicConfig()

url = 'amqp://guest:guest@localhost:5672/%2F'
params = pika.URLParameters(url)
params.socket_timeout = 5

connection = pika.BlockingConnection(params) # Connect to CloudAMQP
channel = connection.channel() # start a channel
channel.queue_declare(durable=True, queue='new-user-confirm-email') # Declare a queue
# send a message

channel.basic_publish(exchange='event', routing_key='new.user', body='{"email":"jeconnol@gmail.com"}')
print " [x] Message sent to consumer"
connection.close()