4

ActiveMQ を使用して、HornetQ を使用するサーバーに 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:]
....
4

1 に答える 1

3

ActiveMQ ライブラリを使用して HornetQ と通信することはできません。それぞれに独自のプロトコルがあり、話すには適切なライブラリが必要であり、それは双方向です。HornetQ ライブラリを使用して ActiveMQ と通信することはできません。

ストンプを使用して、HornetQ と ActiveMQ の間の共通ライブラリである HornetQ と通信できます。

于 2013-04-03T16:34:03.803 に答える