Got the base consumer working and started on celery task for timed feed queues