A message bus implementation on top of celery