Невозможно запустить очередь с мертвой буквы (RabbitMQ / Celery)
Я определил
CELERY_TASK_QUEUES = (
Queue('celeryDrawingRegister', Exchange('celeryDrawingRegisterExchange', type='direct'), routing_key='register.#', queue_arguments={
'x-dead-letter-exchange': 'dlx_exchange'
}),
Queue('celeryDrawingRegisterDLQ', Exchange('dlx_exchange'), routing_key='dlq.#'), # Dead Letter Queue
)
в моем файле settings.py, затем я запускаю своих рабочих, используя
celery multi start devCeleryDatasheetMaitainance devCeleryDocument devCeleryDrawingRegister -A imageTranslateApp -l info -P eventlet --loglevel=DEBUG -c:devCeleryDatasheetMaitainance 3 -c:devCeleryDocument 3 -c:devCeleryDrawingRegister 3 -Q celeryDatasheetMaintainance,celeryDocument,celeryDrawingRegister,celeryDrawingRegisterDLQ
Теперь
мои обычные рабочие и задачи работают нормально, но я не могу использовать celeryDrawingRegister как Dead Letter queues для подтверждения задачи и последующей отправки ее в celeryDrawingRegisterDLQ. Что я здесь упускаю?P.S. Это моя конфигурация Celery
import os
from celery import Celery
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'imageTranslateApp.settings')
app = Celery()
app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()