gistfile1.pyw

    if request.method == "POST":
        email_form = SendAnEmail(request.POST, prefix='emailform')
        if email_form.is_valid():
            connection = DjangoBrokerConnection()
            publisher = Publisher(connection=connection,
                                    exchange="sendemail",
                                    routing_key="sendemail_emails")
            publisher.send(email_form.cleaned_data.get('email_address'))
            publisher.close()
            connection.close()


then in my Celery Task:


        try:
            connection = DjangoBrokerConnection()
            consumer = Consumer(connection=connection,
                                queue="sendemail",
                                exchange="sendemail",
                                routing_key="sendemail_emails")
                
            logger.info("sending emails...")
            for message in consumer.iterqueue():
                logger.info("boo")
                logger.info(message.payload.get('email'))

gistfile2.pyw

from carrot.connection import DjangoBrokerConnection
from carrot.messaging import Publisher, Consumer
connection = DjangoBrokerConnection()
publisher = Publisher(connection=connection, exchange="sendemail", routing_key="sendemail_emails")
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.send({'email': 'some@email.com'})
publisher.close()
connection.close()