Eu tenho uma implantação RabbitMQ existente que alguns aplicativos Java estão usando o envio de mensagens de log como objetos JSON string em vários canais. Eu gostaria de usar o Celery para consumir essas mensagens e gravá-las em vários lugares (por exemplo, DB, Hadoop, etc.).

Eu posso ver que o Celery é design para ser o produtor e consumidor de mensagens RabbitMQ, uma vez que tenta esconder o mecanismo pelo qual essas mensagens são entregues. Existe alguma maneira de obter Celery para consumir mensagens criadas por outro aplicativo e executar trabalhos quando eles chegam?