問題タブ [stomp]

私はストンプとアクティブメッセージングでActiveMQを使用しています。http://code.google.com/p/activemessaging/wiki/Configurationの設定手順に従おうとしました

私のbroker.ymlには、次の構成があります

私のmessaging.rbには...

しかし、これは機能していないようです。メッセージは HiWorld キューに入れられません。どんな助けでも大歓迎です。

前もって感謝します。

マテ

基本的に、異なるマシン (ubuntu) で 2 つの MQ を実行しています。お互いに通信できるようにする必要があります。

次のように、マシン A に自分の broker.yml があります。

発達：

テスト：

製造：

マシン B の broker.yml は次のようになります。

発達：

テスト：

製造：

マシン A がマシン B にメッセージを渡すように apache-activemq/conf/activemq.xml を構成するにはどうすればよいですか。

現在、私の activemq.xml は次のようになっています。

前もって感謝します！

.net メッセージングと、他のオープン プロトコルとの互換性について疑問があります。.net メッセージング API が STOMP プロトコルで動作できるかどうかを知りたいですか? このプロトコルを利用するにはどうすればよいですか? 使用する必要がある特定のライブラリはありますか?

あなたの経験とアイデアを共有してくれてありがとう。

ActiveMQの耐久性のあるクライアントに問題があります。Pythonでstomp.pyを使用しています。

コードからわかるように、clientIdを自分のホスト名に設定しています。添付のスクリーンショット（下）に示されているように、clientIdは「ID：Atlas....」のように表示されます。

問題は、stomp.pyベースのクライアントを切断するたびに、次に再接続したときに新しい「clientId」を取得することです。これにより、ActiveMQのサブスクライバーのリストがいっぱいになります:( 上の画像は、ActiveMQブローカーのサブスクライバーを示しています。次に切断してから接続しても、上記のエントリはそのまま残り、別のエントリが追加されます。すぐにリスト内の多くのサブスクライバー）。

奇妙なことに、セレクターは100％動作します（<>を=に変更して、メッセージが返されるようにすることで確認します）。したがって、clientIdは何らかの形で動作している必要があります。

gitorious で新しいリポジトリを作成しようとすると、次のエラーが発生します。

確認したところ、stomp は確実に実行されており、telnet は正常に接続されています。

問題は何でしょうか？

私が現在インストールしている宝石：

message_processing には、次のものもあります。

私は、大規模なデータベースの特定のデータをリモート Web サイトで利用できるようにするソリューションに取り組んでいます。私が最初に考えたのは、データベースから特定のデータを取得するために、いくつかの SOAP Web サービスを簡単に作成することでした。これは、Zend_Soap_Server のユーザーを使用して、たとえば次のように数行で実行できます。

今、誰かが私にメッセージブローカー/キューも見てみるように言った. 私は apache activeMQ、stomp、zend_queue などのソフトウェアを調べてきましたが、それらが何に使用されるべきか、またこのプロジェクトで役立つかどうかについて明確な見解を得ることはできませんでした。

私の実装には、データベースの応答が速くないときに Web サイトが遅くなったり、Web サイトから多くのリクエストが来るときにデータベースに高負荷がかかるなど、いくつかの欠点がある可能性があることを理解しています。メッセージブローカーはそのような複雑さを防ぐことができますか?

This is related to an earlier question I had asked about what sort of middleware one can use for developing a client/server app.

Among the options suggested, I was intrigued by zeroMQ and its capabilities.

Since morning, I have been researching on using zeroMQ for my application. However, since my client is a Adobe AIR/FLEX, I see a steep curve in using zeroMQ since there are no bindings available for actionscript.

Google search shows a popular client called STOMP that can be used for messaging in flex based applications but there doesn't seem to be any STOMP adapter for zeroMQ either.

This leaves me with other alternatives such as RabbitMQ or ActiveMQ (since they both seem to have STOMP adapters) as possible middleware choices.

How hard/easy it is to develop to stomp adapter for zeroMQ? I hardly found any documentation on writing an adapter. Or is it worth writing an adapter for zeroMQ than focus on, say, using RabbitMQ that supports STOMP.

Finally, what are other popular alternatives to STOMP for Flex on the client side and leverage zeroMQ on the middleware part.

Thanks Dece

ActiveMQ-CPP と stomp プロトコルを使用して永続的なコンシューマーとプロデューサーを作成する際に問題があります。ストンプを使用して HornetQ に接続しようとしていますが、非持続状態でメッセージを送受信できます。メッセージの CMSDeliveryMode とともに配信モードを永続的に設定し、通常のコンシューマーの代わりに DurableConsumer を作成して、プロデューサーを永続的に変更しようとしました。しかし、JBoss JMX-Console を見ると、どちらも非耐久性と見なされていました (メッセージは非耐久性として分類され、コンシューマーも非耐久性としてサブスクライブされます)。

統合テストの StompDurableTest も試してみましたが、20 件のメッセージのうち 10 件しか受信しませんでした (コンシューマーがアクティブなときに送信されたもの)。そのため、テストは失敗しました。

統合テストが機能しなかったため、コードではなく、ActiveMQ-cpp または Stomp の構成に関係していると思います。耐久性を有効にするために何か不足していますか?

前もって感謝します、

サーミ語

コメット機能に Stomp / Orbited を使用しています。

複数のチャンネルを扱うために、私はこれをやっています：

if (frame.headers['destination'] == '/thisFeed/') { //thisFeed を処理する }

if (frame.headers['destination'] == '/thatFeed/') { //thatFeed を処理する }

....それは大丈夫だと思います。しかし、ロード時にフィードをどのように処理したいのかわからない場合はどうすればよいでしょうか? 私はこのようなことができるようにしたい:

stomp.subscribe('someOtherFeed', someOtherFeedHandler);

そうすれば、サブスクライブするときに、そのときだけハンドラーを定義できます。

http://dev.coravy.com/wiki/display/OpenSource/Stomp+client+for+Objective-Cで指定された指示を使用して、Stomp Objective-C クライアントをかなり単純なアプリケーションに統合しようとしています。

アプリは正常にコンパイルされますが、ホストに接続しようとしても応答がありません。STOMP コードをブレークポイントした後、AsyncSocket.m:3641 でのこの呼び出しが常に NO を返すことがわかりました。

これに対処する方法について何か助けていただければ幸いです。