amqp.exceptions.PreconditionFailed: Queue.declare: (406) PRECONDITION_FAILED - неэквивалентный аргумент

Question

Я пытаюсь использовать задачу Celery из очереди Rabbitmq.

Мой файл tasks.py ниже

from celery import Celery

app=Celery('tasks',broker ='amqp://localhost//')

app.conf.task_default_queue = 'e'

@app.task(name='hello')
def hello():
  print('hello')

и

import pika

connection = pika.BlockingConnection(
pika.ConnectionParameters(host='localhost'))
channel = connection.channel()

channel.queue_declare(queue='e')

def callback(ch, method, properties, body):
    print(" [x] Received %r" % body)

channel.basic_consume(
    queue='e', on_message_callback=callback, auto_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()

Но я получаю эту ошибку amqp.exceptions.PreconditionFailed: Queue.declare: (406) PRECONDITION_FAILED - неэквивалентный аргумент Я не знаю почему?