I can't connect to Activemq
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
- 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
The Activemq version is apache-activemq-5.10.0
Can you help me ?