consumer.py

import pika, os, logging, time
logging.basicConfig()

def send_email(msg):
  print msg
  print "sending email"
  time.sleep(5) # delays for 5 seconds
  print "email sent";
  return;

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

connection = pika.BlockingConnection(params)
channel = connection.channel() # start a channel

def callback(ch, method, properties, body):
  send_email(body)

channel.basic_consume(callback,
  queue='new-user-confirm-email',
  no_ack=True)

# start consuming (blocks)
channel.start_consuming()
connection.close()