celery 广播问题

[ray1888]

我按官网文档上面的来添加了这段代码在 celery_config 里面

CELERY_QUEUES = (Broadcast(name='broadcast_tasks',),)

#
CELERY_ROUTES = {
    'celery_task.method.get_new_method': {
      'queue': 'broadcast_tasks',
      # 'exchange': Exchange(type='fanout')
    }
}

启动的时候会直接报错

PreconditionFailed: Exchange.declare: (406) PRECONDITION_FAILED - inequivalent arg 'type' for exchange 'broadcast_tasks' in vhost '/': received 'fanout' but current is 'direct'

环境是 py2.7+ celery4.2 + rabbitmq 3.6 是什么原因导致这个问题，搜了 stackoverflow 也没看到有好的解决方法

[ray1888]

换了使用在 app 文件中启动前加了如下配置可以启动了，但是现象比较奇怪
```
app.conf.task_queues = (Broadcast('broadcast_tasks'),)
app.conf.task_routes = {
'celery_task.method.get_new_method': {
'queue': 'broadcast_tasks',
'exchange': 'broadcast_tasks'
}
}
```
从 rabbitmq 控制台上面能够看到信息被推进了 broadcast 信道，但是无法被消费

[hustlibraco]

@ray1888 我也遇到无法被消费的问题，请问解决了吗