我尽量写的简介一点，说一下背景：
celery调用rabbitmq进行消息消费，但是不作为生产者使用；
生产者：java发送（或者其他非celery发起的消息队列形式）
消费者：celery
原来的生产者：apply_async（）函数
只发了消息体，发现各种celery消费不了的情况。
（都是干货）
以下都是各个人的解决方法以及我自己的
1、从github源码处，获取了issue的解决方法1：pip uninstall librabbitmq -- 失败
2、给消息队列接受消息时，将连接从amqp改为pyamqp -- 失败
3、增加一些别的，celery的参数 -- 失败
忘了说了，我得工程是jango起的，不知道非jango有没有遇到这个问题，有的话评论区说一声；
我的分析方法：
从源码中进行日志打印（很气，有些地方加了print就没有任何反应，一启动就自动cancel）
对比celery的启动方式以及celery的消息格式；
给消息格式模拟增加各种参数、headers等；
**最终成果：**
成功
celery必须要指定一个task的headers参数，以提供给celery监控获取消息后，传送到对应的函数位置；
celery会有指定的消息体格式[[消息内容],{},{}]，具体分析我没深入了，原因可能是为了回调能获取到参数之类的，不然就会取消celery的启动或者取消消息接收；
如果按照我这里的方法不成功，看看上方提供的其他两个方法