Предупреждение сельдерея «Получено и удалено неизвестное сообщение»

Я настраиваю задачу в Celery, чтобы она «потребляла» из определенного обмена темами. Когда я отправляю сообщение на соответствующий обмен, я получаю сообщение об ошибке: «Получено и удалено неизвестное сообщение. Неверный пункт назначения?!?» на консоли сельдерея.

Я сделал отдельную папку проекта, чтобы воспроизвести проблему, где все называется test-something со следующей структурой:

celery-test/  
  L celery.py  
  L celeryconfig.py  
  L tasks.py

Я видел различные вопросы StackOverflow и проблемы GitHub, касающиеся пакета librabbitmq. Решение здесь состояло бы в том, чтобы удалить этот пакет, но он даже не установлен, так что это ни к чему меня не привело. Некоторые из найденных вопросов/проблем, которые предлагают это решение:
- https://github.com/сельдерей/сельдерей/issues/3675
- Celery &Rabbitmq:WARNING/MainProcess] Получено и удалено неизвестное сообщение. Не тот пункт назначения?!? - эксперимент на ЖКТ

Я также пробовал играть с настройками маршрутизации задач, так как я предполагаю, что проблема заключается в банкомате, но я не могу заставить его работать.

Для тех, кто интересуется, почему порт выключен на 1, это потому, что он указывает на rabbitmq в моем контейнере докеров, который больше не может использовать 5672.

celery.py

app = Celery('celery_test', include=['celery_test.tasks'])
app.config_from_object('celery_test.celeryconfig')

celeryconfig.py

broker_url = 'amqp://guest:guest@localhost:5673//'
result_backend = 'rpc://'

default_exchange = Exchange('default', type='direct')
test_exchange = Exchange('test_exchange', type='topic')
task_queues = (
    Queue('default', default_exchange, routing_key='default'),
    Queue('test_queue', test_exchange, routing_key='test123test')
)

task_routes = {
    'celery_test.tasks.test_method': {
        'queue': 'test_queue'
    }
}

задачи.py

@app.task
def test_method():
    print('test_method')
    return 'test_method'

И затем файл, который я использовал для отправки сообщения: send.py

connection = pika.BlockingConnection(pika.URLParameters('amqp://guest:guest@localhost:5673/'))
channel = connection.channel()

exchange = 'test_exchange'
routing_key = 'test123test'
message = 'Testmessage'

channel.exchange_declare(exchange=exchange, exchange_type='topic', durable=True)

channel.basic_publish(exchange=exchange, routing_key=routing_key, body=message)
connection.close()