activeMQ amqp错误

Question

我正在使用activeMQ而不是rabbitMQ，但在使用log4net的“应用程序发行商”上仍然使用amqp协议。

但在将消息发布到activeMQ时出现以下错误，并在此处进行了相关讨论：http://activemq.2283324.n4.nabble.com/AMQP-version-AMQP-header-mismatch-value-0-expecting-1-td4663920.html

INFO | ActiveMQ WebConsole available at http://localhost:8161/
 INFO | Initializing Spring FrameworkServlet 'dispatcher'
 INFO | jolokia-agent: No access restrictor found at classpath:/jolokia-access.xml, access to all MBeans is allowed
org.apache.activemq.transport.amqp.AmqpProtocolException: Could not decode AMQP frame: hex: 414d515001010009
        at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:227)
        at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onAMQPData(AmqpProtocolConverter.java:217)
        at org.apache.activemq.transport.amqp.AMQPProtocolDiscriminator.onAMQPData(AMQPProtocolDiscriminator.java:87)
        at org.apache.activemq.transport.amqp.AmqpTransportFilter.onCommand(AmqpTransportFilter.java:96)
        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(Unknown Source)
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:202)
        at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:224)
        ... 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:1213)
        at org.apache.qpid.proton.engine.impl.TransportImpl.processInput(TransportImpl.java:1175)
        ... 9 more

Answer 1

我认为您使用的客户端版本不正确。

注意: RabbitMQ客户端是0-9-1，而ActiveMQ是AMQP1.0。

查看这篇文章：Apache Camel AMQP - ActiveMQ AMQP header mismatch value 1, expecting 0