ActiveMQ到HornetQ导致异常

Question

我正在尝试使用HornetQ向服务器发送一条使用ActiveMQ的JMS消息，但遇到了一些困难。我认为这样做是完全合理的，所以我怀疑我这端有某种(可能是微不足道的)操作符错误。有什么可以在这里发现的或者我应该看看的东西吗？尝试创建会话时出现错误：

在我这一端，我做了以下事情：

 final ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, serverUrl);
 connection = connectionFactory.createQueueConnection();
 session = connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

在服务器端，他们看到了以下内容：

11:53:06,428 ERROR [org.hornetq.core.protocol.core.impl.RemotingConnectionImpl] (Old I/O server worker (parentId: 1778858866, [id: 0x6a073b72, -hostname-])) 
Failed to decode: java.lang.IllegalArgumentException: Invalid type: 1
at org.hornetq.core.protocol.core.impl.PacketDecoder.decode(PacketDecoder.java:550) [hornetq-core-2.2.13.Final.jar:]
....

Answer 1

您不能使用ActiveMQ库与HornetQ对话。每一个都有它自己的协议，你需要合适的库来通信，这是双向的。您不能使用HornetQ库与ActiveMQ对话。

您可以使用stomp与HornetQ对话，这是HornetQ和ActiveMQ之间的一个通用库。