問題タブ [apollo]

ActiveMQがJMSXUserIDプロパティをサポートしていることを知っています。

http://activemq.apache.org/jmsxuserid.html

ActiveMQの代わりにApollo（ActiveMQサブプロジェクト）を使用しようとしていますが、現時点では、Apolloで同じ動作を再現しようとして立ち往生しています。

私は仕組みにこだわるわけではありませんが、一言で言えば、認証されたユーザーからのすべての着信メッセージに、どのユーザーがどのメッセージを送信したかを知らせる識別子をタグ付けする方法が必要ですが、ユーザーがなりすますことはできません自分自身を設定します。これは基本的に、ActiveMQでJMSXUserIDが使用されるものとまったく同じですが、Apolloで同じことを行う方法がわからないようです。

私は何が欠けていますか？

ActiveMQはすべてのページでApolloにリンクしているため、これはGoogleにとって特に難しいと感じています。そのため、ほとんどの検索結果は役に立ちません。

前もって感謝します。

Windows Server2008R2で実行されているApollo1.3に問題があります。Webアプリケーション（stomp-phpを使用するPHP）からSTOMPメッセージを送信しています。このメッセージは、Windowsサービスとして実行されているアプリケーションで処理されます。これはしばらくの間は正常に機能しますが、メッセージをApolloにプッシュすると、突然、「仮想ホストが停止しました」というエラーが発生します。

Apolloはまだ実行中であり、Webインターフェイスから仮想ホストにアクセスすることもできます。（これまでに見つけた）サービスを再度実行する唯一の方法は、サービスを停止して、ブローカーのデータフォルダー内のすべてを削除し、サービスを再開することです。サービスを再起動するだけでは機能しません。

apollo.logのスニペットは次のとおりです。

これらは私が見つけることができる唯一の例外です。

コードの問題というよりは構成エラーだと思いますが、関連するコードスニペットは次のとおりです。

これは、仮想ホストが一定時間非アクティブ（つまり、メッセージや接続を受信しない）のときにトリガーされると思います。したがって、これがトリガーされないように、時々apollo-brokerを再起動することを考えていましたが、これが実際に仮想ホストを停止するトリガーになるかどうかはわかりません。

仮想ホストが突然停止する理由と、これを防ぐために必要な構成の変更を誰かに教えてもらえますか？ドキュメントを検索しましたが、仮想ホストの存続期間などについては何も見つかりませんでした。

Windows 7 32 ビットでブローカーがサービスとして実行されている C# フレームワーク 4.0 を使用すると、安定版と開発版の両方で次のエラーが表示されます。

この結果、クライアントでコールがブロックされ、例外に応答する前にセッションがタイムアウトするため、一時キューを使用できなくなります。

ActiveMQ5.6からApollo1.5に切り替えようとしています。トピックのパブリッシュ/サブスクライブを使用してメッセージを交換する2つのソフトがあります。

• 最初のものはc++であり、tcpでopenwireを使用します
• 2つ目はJavascriptで、WebSocketでstompを使用します

ActiveMQを使用すると、すべてが正常に機能し、送信したメッセージは両方のソフトで読み取りと書き込みが可能であり、それ以降、クライアントを変更しませんでした。

ここで、（openwireを使用して）c ++ソフトからメッセージを送信し、JSソフトでそれらを読み取ろうとすると、エラーが発生します。実際、ヘッダーのコンテンツタイプが「protocol / openwire」のメッセージを受け取りますが、stompを期待しています。

これは私がapollo.xmlコネクタセクションを設定した方法です：

また、クライアントプロトコルを自動検出することになっているtcpおよびwsコネクタで<detect />を試してみましたが、どちらも機能しません。

誰かが私がこれを理解するのを手伝ってくれる？

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

編集 ：

stompプロトコルメッセージを受信して​​いることがわかりましたが、それらは非常に奇妙な形式であり、stomp.jsがメッセージの解析に失敗してメッセージ本文を正しく埋めることができない非テキスト文字が含まれています。

これは、activemq openwireから一度受信した同じメッセージで、同じc++パブリッシャーとjsサブスクライバーでapolloopenwireを受信します。

activemq

アポロ

アポロで問題になると思いますか？

Scala 用の HawtDispatch Apollo Client ライブラリを使用して、Apollo 用の Camel コンポーネントを開発するのに忙しくしています。キューとトピックからのメッセージの送受信には成功していますが、現在のプロデューサー (StompProducer) が inOut または InOnly の動作を必要としているかどうかを判断する方法がわかりません。InOut の場合、明示的な replyTo が指定されていない場合、結果を取得するために一時キューにサブスクライブしたいと考えています。私は間違った木を吠えていますか？私が見ることができる例はありますか？誰かが既に Apollo Stomp コンポーネントを作成しましたか? Apollo 1.5 で ActiveMQ コンポーネントを使用して OpenWire プロトコルにバインドしようとしましたが、うまくいきませんでした。Camel 2.11-SNAPSHOT の Sjms Camel コンポーネントも機能しませんでした。最終的な目標は、Akka 用の Apollo コンシューマー/プロデューサー アクターを用意することです。Camel Apollo 統合の代替案や、コンポーネントを機能させるための独自の試みについてのアドバイスをいただければ幸いです。よろしくイアン

ASP.NET MVC アプリケーションでキューを操作する必要があります。最速の実装を探して、少しググって、いくつかのベンチマークを調べたところ、現時点では Apache Apollo MQ がメッセージ キュー全体で最速のソリューションであることがわかりました。

.NET の世界で Apache ApolloMQ (メッセージの送信と消費) を操作できるクライアント ライブラリがいくつか存在しますか?

また、他のソリューション (0MQ を除く) がより優れたパフォーマンスを示すベンチマークを提供していただける場合は、リンクを提供してください。

こんにちは、私は Apollo Activemq Broker と Stomp を使用しています。
メッセージをブローカーに送信するためのメソッドと、キューからメッセージを読み取るためのメソッドを 2 つ作成しました。
ボーカーに 1 つのメッセージを送信してから、それを読むと、すべて問題ありません。メッセージを読んで確認できます。送信メッセージを複数回実行し、キューに多くのメッセージがあるときに問題が発生します。キューから最初のメッセージのみを受信するたびに、メッセージを読んで確認します。また、ループを実行すると "

すべて問題ありません。キューからすべてのメッセージを読み取って確認できます。

UPDATE : PHP から ack を受信したときに、ActiveMQ がキューからメッセージを削除しない。Ack は true を返しますが、メッセージはまだキューにあります。

更新: 私の問題は、デフォルトが 1000 の "prefetchSize" にあるようです。これを 1 に設定したいのですが、stomp を使用してブローカーと対話します。その値を 1000 から 1 に変更する必要がある場合は、ヒントを教えてください。

fusesource コードを使用して mqtt メッセージを Apollo サーバーに公開すると問題が発生します。次のようなコードでメッセージパブリッシャーを書きました

トピックにサブスクライブするメッセージ コンシューマーも作成しました。最初にコンシューマーを開始し、次にパブリッシャーを開始した場合、コンシューマーはすべてのメッセージを正しく取得できます。ただし、最初にパブリッシャーを開始してからコンシューマーを開始すると、コンシューマーはメッセージを受信しません。また、Apollo 管理コンソールにアクセスしましたが、キューにメッセージが見つかりませんでした。(添付のスクリーンショットを参照してください)。

この問題を解決するにはどうすればよいですか? コンシューマーを常に実行することはできませんでした。パブリッシャーからのメッセージを失いたくありません。コンシューマーがオフラインの場合、ブローカー (Apollo) はすべてのメッセージを保持するべきではありませんか? はいの場合、なぜ私はそれを見ることができなかったのですか?

これはばかげた質問のように思えますが、私は MQTT にかなり慣れていないので、助けが必要です。

私は ActiveMQ を初めて使用します (ブローカーには Apollo を使用しています)。クラスがactivemq-all-5.5.0.jarに存在しないことを除いて、私が読んだすべてのものは、接続プールにorg.apache.activemq.pool.PooledConnectionFactoryを使用するように言っています。jarfinder.com によると、そのクラスは古いバージョンの ActiveMQ にしか存在しません。

春か何かを含める必要がありますか？1 つのプール接続はどのように行われますか?

ありがとう