org.apache.activemq.transport.amqp.AmqpProtocolException: Could not decode AMQP frame: hex: 414d515000000901
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:619)
Caused by: org.apache.qpid.proton.engine.TransportException: org.apache.qpid.proton.engine.TransportException: AMQP header mismatch value 0, expecting
In state: HEADER5
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 0, expecting 1. In state: HEADER5
at org.apache.qpid.proton.engine.impl.FrameParser.input(FrameParser.java:202)
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
var amqp = require("amqp");
var connection = amqp.createConnection({host:"127.0.0.1",port:5672,login:"admin",password:"admin"});
connection.on('ready',function(){ console.log("AMQP IS CONNECT"); connection.queue("demo",function(q){ q.bind("#"); q.subscribe(function(message){ console.log(message); }); }); });
This‘s my code , Then , I run it ~
Then , the Activemq error:
org.apache.activemq.transport.amqp.AmqpProtocolException: Could not decode AMQP frame: hex: 414d515000000901 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:619) Caused by: org.apache.qpid.proton.engine.TransportException: org.apache.qpid.proton.engine.TransportException: AMQP header mismatch value 0, expecting
The Activemq version is apache-activemq-5.10.0
Can you help me ?