У меня есть существующее развертывание RabbitMQ, в котором несколько приложений Java используют сообщения журнала отправки в виде строковых объектов JSON на различных каналах. Я хотел бы использовать Celery, чтобы использовать эти сообщения и записывать их в разные места (например, в DB, Hadoop и т. Д.).

Я вижу, что Celery является как производителем, так и потребителем сообщений RabbitMQ, поскольку он пытается скрыть механизм доставки этих сообщений. Есть ли способ заставить Celery использовать сообщения, созданные другим приложением, и запускать задания по мере их поступления?