This is a python implementation of RabbitMQ lifecycle, faking a distributed environment talking one each other by messages, this project was based in tutorial available in RabbitMQ page as well as Celery documentation.
You'll find two directories:
app/pure/
app/tasks/
Files available in /pure directory implements just the message broadcast.
Files available in /task directory implements an example using Celery to queue tasks.
Python 2.7.3 (Available by box)
vagrant up
vagrant ssh producer
vagrant ssh rabbit
vagrant ssh consumer
vagrant ssh redis
In 'producer' machine run: ``python send.py`
In 'consumer' machine run: ``python worker.py`
In 'producer' machine run:
python producer.py
In 'consumer' machine run:
sh start.sh OR celery -A tasks worker --loglevel=info