ActiveMQ to HornetQ вызывает исключение

Question

Я пытаюсь отправить сообщение JMS с помощью ActiveMQ на сервер с использованием HornetQ, и у меня есть некоторые трудности. Я думаю, что это вполне разумная вещь, поэтому я подозреваю, что на моем конце есть какая-то (вероятно, тривиальная) ошибка оператора. Есть ли что-то, что можно увидеть здесь или что-то, на что я должен взглянуть? Ошибка происходит при попытке создать сеанс:

С моей стороны, я делаю следующее:

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.