从Celery发送消息时发生ActiveMQ异常

Question

我正在尝试配置

celery==3.1.24

与

apache-activemq-5.10.0

在pythondjango应用程序中。在

当我运行应用程序时，在activemq控制台中出现以下异常。在

org.apache.activemq.transport.amqp.AmqpProtocolException: Could not decode AMQP frame: hex: 414d515001010009 at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:233) at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onAMQPData(AmqpProtocolConverter.java:224) at org.apache.activemq.transport.amqp.AMQPProtocolDiscriminator.onAMQPData(AMQPProtocolDiscriminator.java:89) at org.apache.activemq.transport.amqp.AmqpTransportFilter.onCommand(AmqpTransportFilter.java:98) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) at java.lang.Thread.run(Thread.java:745) Caused by: org.apache.qpid.proton.engine.TransportException: org.apache.qpid.proton.engine.TransportException: AMQP header mismatch value 1, expecting 0. In state: HEADER4 at org.apache.qpid.proton.engine.TransportResultFactory$TransportResultImpl.checkIsOk(TransportResultFactory.java:116) at org.apache.qpid.proton.engine.impl.TransportImpl.input(TransportImpl.java:220) at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:230) ... 7 more Caused by: org.apache.qpid.proton.engine.TransportException: AMQP header mismatch value 1, expecting 0. In state: HEADER4 at org.apache.qpid.proton.engine.impl.FrameParser.input(FrameParser.java:186) at org.apache.qpid.proton.engine.impl.FrameParser.process(FrameParser.java:502) at org.apache.qpid.proton.engine.impl.TransportImpl.process(TransportImpl.java:1265) at org.apache.qpid.proton.engine.impl.TransportImpl.processInput(TransportImpl.java:1226) ... 9 more

可能是什么问题？在

Answer 1

我不认为芹菜支持ActiveMQ。 这是它的FAQ。在