1

hornetq jms サーバーと通信するように C クライアントをセットアップしようとしています。C側でlibstompを使用してSTOMPアクセプターを使用しています。

私の C クライアント コードは、パスフレーズと宛先キュー名が (Java クライアントからアクセスできる有効なキューに) 変更された、libstomp ページの逐語的な例です。

これを実行すると、次のようになります。

Connecting......OK
Sending connect message.OK
Reading Response.Response: CONNECTED,
OK
Sending Subscribe.OK
Sending Message.OK
Reading Response.Response: ERROR, org.hornetq.core.protocol.stomp.StompException:     Client must set destination or id head
er to a SUBSCRIBE command
        at     org.hornetq.core.protocol.stomp.StompProtocolManager.onSubscribe(StompProtocolManager.java:    339)
        at     org.hornetq.core.protocol.stomp.StompProtocolManager.handleBuffer(StompProtocolManager.java:196)
        at     org.hornetq.core.protocol.stomp.StompConnection.bufferReceived(StompConnection.java:279)
        at     org.hornetq.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferRec    eived(RemotingServ
iceImpl.java:512)
        at     org.hornetq.core.remoting.impl.netty.HornetQChannelHandler.messageReceived(HornetQChannelHa    ndler.java:73)
        at     org.jboss.netty.channel.SimpleChannelHandler.handleUpstream(SimpleChannelHandler.java:100)
        at     org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChannelPipeline.java:372)
        at     org.jboss.netty.channel.StaticChannelPipeline.sendUpstream(StaticChannelPipeline.java:367)
        at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:274)
        at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:261)
        at org.jboss.netty.channel.socket.oio.OioWorker.run(OioWorker.java:100)
        at     org.jboss.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
        at     org.jboss.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:44)
        at     org.jboss.netty.util.VirtualExecutorService$ChildExecutorRunnable.run(VirtualExecutorServic    e.java:181)
        at     java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at     java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:662)
OK
Sending Disconnect.OK
Disconnecting...OK

要するに、サーバーから次の例外が発生します。

ERROR, org.hornetq.core.protocol.stomp.StompException: Client must set destination or id header to a SUBSCRIBE command

例の 92 行目で、目的地を設定します。

apr_hash_set(frame.headers, "destination", APR_HASH_KEY_STRING, "/queue/FOO.BAR");

それにもかかわらず、メッセージがサーバーに到達してヘッダーを解析すると、 map が取得されますが、キーation -> /queue/FOO.BARを探していdestinationます。クライアントが正しいマップ エントリをヘッダーに追加しており、ネットワークに送信するまで破損していないことを確認しました。

何が間違っている可能性があるかについての指針はありますか？

PS hornetq は 2.2.9.Final です。libstomp は svn の最新リビジョン (rev 90 - http://svn.codehaus.org/stomp/trunk/c/ ) で、apr 1.4.6 でコンパイルされています。すべてWin-7で動作

4

1 に答える 1

1

2.2.9 はかなり古い HornetQ リリースです。2.2.14 または最新の 2.3.beta で再試行する必要があります。HornetQ マスターの git のコードを見たところ、宛先が処理されています

https://github.com/hornetq/hornetq/blob/master/hornetq-server/src/main/java/org/hornetq/core/protocol/stomp/VersionedStompFrameHandler.java#L254の onSubscribe() を参照してください。

FWIW、HornetQ では、.宛先の除数としてドットが使用されます (コードはスラッシュを使用しています/)。STOMP プロトコルは、これを実装依存の規則として残しています。

于 2013-01-08T14:19:47.173 に答える