問題タブ [stomp]

Apache Fuse5.5はstomp1.1を完全にサポートしていますか？

Pythonクライアントから「NACK」を送信しようとしています。接続はバージョン1.1で行われます

しかし、「NACK」を送信すると、例外がスローされます2012-01-20 13:46:03,815 receiver ERROR Received server error - messageNACK received but connection is in v1.0 mode。

これに関して私を助けてください。

stompプロトコルを使用してActiveMQサーバーと通信するには、PythonSTOMPクライアントを使用する必要があります。私はいくつかのPythonSTOMPクライアントライブラリを検索し、それらのいくつかを見つけましたが、それらはSTOMP1.0のみを実装しています。ただし、ハートビートのサポートなど、STOMP 1.1プロトコルのいくつかの機能が必要なので、STOMP1.1Pythonクライアントライブラリを探しています。STOMP 1.1 Pythonクライアントライブラリはありますか？

また、フェイルオーバー機能をサポートするPythonクライアントライブラリはありますか？

[更新] stomppyはSTOMP1.1をサポートしているようですが、自動フェイルオーバーをサポートするクライアントがまだありません。

Apache ActiveMQ (5.5.1) と一緒に Python (2.6) で stomp.py (3.0.5) を使用します。基本的な例は問題なく動作しましたが、受信したメッセージ (on_message() 内) を MyListener クラスの外部の変数に返したいと考えています。

これはかなり標準的なタスクだと想像できますが、私の一般的な Python スキルは、その方法を理解するには十分ではありません。より高度な例を求めてグーグルをトロールし、グローバル変数について調べましたが、メッセージを画面に出力するだけでなく、変数にメッセージを入れることがまだできないようです。

どんな助けでも大歓迎です！

Java用のいくつかのストンプライブラリ（gozirra、stompj、activemq）を試しています。これらのライブラリはすべて、例が 1 つしかないなど、ドキュメントが貧弱であり、深刻な問題があります。

SSL サポートが必要です。

stomp+ssl プロトコルが存在し、activemq でサポートされていますが、それをサポートする Java クライアントを見つけることができません。

ActiveMQがVeriFIXと通信するためのクライアントとしてstomp.pyを使用しています。VerifixはJMSを使用します。

コマンドを送信するAPIトピックと、応答を受信するAPI.RESPONSEトピックがあります。

ヘッダーのみがstompクライアントに到着し、実際のペイロードには到着しません。

ActiveMQがSTOMPクライアントにメッセージをシリアル化する方法を知るために、メッセージ変換を構成する必要があるようです。

http://activemq.apache.org/stomp.htmlは、XStream（XML）とJettison（JSON）について言及しています

XStreamまたはJettisonを構成するにはどうすればよいですか？

（編集済み）解決策：

解決策は、「変換」ヘッダーを含めることです。

有効な値は次のとおりです：jms-map-jsonまたはjms-map-xml

サブスクライブフレームは次のようになります。

これを見つけた後でも、ActiveMQのドキュメントで見つけることができません。

これはどこかに文書化されていますか？

私がやろうとしているのは、websocket 経由で stomp を使用して 20 ～ 120KB のメッセージをトピックに送信することであり、以下のエラーがスローされます。どんな助けでも大歓迎です。

警告 | java.lang.IllegalStateException の処理に失敗しました: org.eclipse.jetty.websocket.WebSocketConnectionD00.handle(WebSocketConnectionD00.java:164) の org.eclipse.jetty.websocket.WebSocketParserD00.parseNext(WebSocketParserD00.java:104) で FULL。 org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:43) の org.eclipse.jetty.util.thread の eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:545) .QueuedThreadPool.runJob(QueuedThreadPool.java:598) at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:533) at java.lang.Thread.run(Thread.java:722)

PHPプロジェクトでRabbitMQの代替品を探しています。これまでに検討している2つのオプションは、KestrelとQpidです（AMQPを使用することにした場合（これは避けたい））。RabbitMQでは、メッセージをエクスチェンジ（宛先）に送信できます。エクスチェンジ（宛先）は、メッセージを配信するキューまたはトピック（JMS用語）を決定します。STOMPサーバー（ActiveMQ / ApolloまたはHornetQ）を選択できないのは、STOMPでメッセージを宛先に送信して、メッセージを複数のキュー（JMS内）に配信できるかどうかがわからないことです。条項）？送信者は、メッセージを配信する必要があるキューを認識していないはずです。

ありがとうございました。

Ubuntu Linux 10.04 に Karaf (2.2.5) をインストールしました。Karaf の上に機能として ActiveMQ をインストールしました。ストンプ コネクタを使用してカスタム ブローカーを作成しました。Java クライアントからこのストンプ ブローカーに接続しようとすると、「java.net.SocketTimeoutException: Read timed out」というメッセージが表示されます。

ActiveMQ をスタンドアロン アプリケーションとして起動すると、同じクライアントが正常に動作します。

前もって感謝します

これが私の設定です：

Perl の Net::Stomp を使用して Active MQ トピックにメッセージを送信しようとしています。反対側では、Java クライアントがトピックを監視し、そこからメッセージを取得します。Active MQ は Spring フレームワークに基づいており、Spring config.xml で以下を定義しています。

Perl から送信されたメッセージは、反対側の Java クライアントによってまったく取得されていません。perl コードは次のようになります。それに何か問題がありますか？

私もこの$stomp->send方法を使用しましたが（上記でコメントアウト）、どちらも機能しません。次に、STOMP がメッセージをフレーム化して送信する必要があることをどこかで読んだので、メッセージをフレーム化しました。MQ Java リスナーは、(他の Java クライアントから) TCP 経由でポート 61616 に着信するメッセージに対して正常に動作しますが、Perl から 61613 (複数のメッセージ プロデューサー) に対しては動作させることができません。私がグーグルで検索したところ、多くの人が PHP から Java への変換を行っていることがわかりましたが、Perl から Java への変換の例は 1 つもありませんでした。Stomp メッセージを Java モニター側 (コンシューマー) で処理する必要がある、または通常の onMessage 実装 (TCP など) が機能する別の方法はありますか?

アプリケーションのグローバルな状態を維持するサーバーがあります。

クライアントはサーバーに接続し、グローバル状態の変化に関するメッセージを取得できます (サーバーが情報をブロードキャストするためのパブリッシュ/サブスクライブ メカニズム)。

ただし、起動時には、クライアントはグローバル状態に関する情報をまったく持っておらず、それを必要としています。私が望むのは、システムにサブスクライブする新しいクライアントの場合です。最初の通知メッセージは、アプリケーションの完全な状態です。次に、この状態に関する変更のみを受け取ります。

1. クライアントがメッセージング システムに接続する
2. メッセージングシステムにサブスクライブします
3. 取得する最初のメッセージは、システムの完全な状態です
4. 次に、グローバル状態に関する変更のみを受け取ります

この考え方は、新しいプレーヤーが最初にゲームの完全な状態を取得する必要があるマルチプレーヤー ゲームに似ており、その後、ゲームの変更のみが送信されます。

ActiveMQ や Stomp などのメッセージング システムは、複数の言語に対応し、複数のトランスポート レイヤーで使用できるため、私のニーズには適しています。ただし、完全な状態を送信する (または一貫した方法で最後の変更を累積する) という概念はありません。

もちろん、この状態を静的な方法で簡単に提供することもできます (最初に完全な状態を取得し、次にパブリッシュ/サブスクライブ システムにサブスクライブします)。完全な状態を処理している間? この変更は、取得したばかりのグローバル状態で既に考慮されていますか? ...)。ただし、Stomp と ActiveMQ によって既に提供されている多言語/複数トランスポートの側面は失われます。

それを行うための既存のライブラリ/ツールはありますか? ActiveMQ の何らかの拡張機能はありますか? ストンプに似た何か？それとも手作りする必要がありますか？