問題タブ [activemq]

スプリング注入エンドポイントの例は次のとおりです。

別のサーバーの特定のポートに接続するようにクライアント モード エンドポイントを設定するにはどうすればよいですか?

インバウンド接続をリッスンするようにエンドポイントを構成するにはどうすればよいですか? (この例は、説明的な ID で示されるようにリスナーのようですが、なぜですか?)

注: 私は実際には HL7 プロトコルまたはコーデックを使用していません。独自のプロトコル コーデック用に独自に開発する予定です。

ActiveMQ-CPP 2.2.1 Visual Studio 2005 プロジェクトをコンパイルして実行しています。コンソール ウィンドウでは、メッセージは受信されていませんが、送信されていることが示されます。ActiveMQ-CPP 2.0.1 ではメッセージを送受信できますが、2.2.1 ではできません。私は ActiveMQ を初めて使用し、どこからトラブルシューティングを開始すればよいかさえわかりません。考え/提案/開始するのに適した場所は、大きな助けになります。

役に立ったら、私は ActiveMQ 5.1.0 バイナリを使用しています。

前もって感謝します！

ActiveMQで問題が発生しているので、すべてのActiveMQアクティビティをトレース/表示したいと思います。私が見つけることができる唯一のログファイルは、永続データに関連付けられているものです（これがオンになっている場合）。ActiveMQの内部で何が起こっているのか、そしてなぜ私のコンシューマーがメッセージを消費していないのかを教えてくれる、私が表示または生成する他のログファイルはありますか？他に何か提案はありますか？

前もって感謝します！

activemq に付属の例をコンパイルしようとしています

apache-activemq-5.1.0\example\src\ 内

TopicPublisher.java、CommandLineSupport.java

netbeans を介してコンパイルすると、javax.jms が存在しないという参照の問題が発生します。

j2ee.jar、openjms、sun jms を試しましたが、すべて同じエラーが発生します。

また、org.apache.activemq.util が存在しないことについて不平を言っていますが、activemq-all-5.1.0.jar を参照しています。

注：外部jarへの他のすべての参照は正常に機能しています

何か案は？

編集：参照する必要があるjarは

libフォルダーのactivemqバイナリdistにあります

TCP から TCP へのルートを示す簡単なデモを ActiveMQ で開始しようとしています。activemq.xml 構成ファイルのキャメル コンテキストでエンドポイントとルートをコーディングしています。

なぜこれがうまくいかないのですか？

AMQ サーバーがリッスン ポートを開いていないようです。

編集: ここでの目的は、単純なデモンストレーションとして、2 つの telnet ターミナル (A と B) を使用して ActiveMQ に接続し、メッセージ キュー サーバーを介して一方から他方へメッセージをルーティングできるようにすることです。後で、コンテンツに基づいてフィルタリングまたはルーティングを試みる場合があります。

activemq と min の簡単なデモをセットアップしようとしています。activemq.xml ファイルの camelContext を編集して、2 つの mina tcp ソケット、2 つのキュー、およびルートなどを含めました。

リスナーA -> qA -> リスナーB リスナーB -
> qB -> リスナーA

その目的は、2 つの telnet セッション間で双方向のパス スルーを行うことです。後で、フィルター処理、トピックへのルーティング、各リスナーの独自のコーデックなどの高度な機能を追加します。

ここに私のキャメルコンテキストがあります:

activemq を開始すると、例外が発生します。

org.apache.camel.NoSuchEndpointException: 次のエンドポイントが見つかりませんでした: mina:tcp://localhost:42000?textline=true

ミナビーンを明示的に追加する必要がありますか? もしそうなら、どこで、どのように？

Apache.NMSおよびApcahe.NMS.ActiveMQ（バージョン1.0）ライブラリを使用してWindowsサービスを作成しました。このサービスは、ベンダーサーバーからのActiveMQからのメッセージを消費します。

サービスは接続を起動し、メッセージをリッスンします（OnMessageイベントを処理します）

接続はトランザクション接続であるため、各メッセージの後にcommitを呼び出します。

サービスが開始されると、すべてが非常にうまく機能し、しばらくの間機能します。ただし、しばらく実行すると、メッセージは消費されなくなります。サービスをリセットしても。通常、サービスとベンダーサーバー（tomcat）を再起動すると、問題が解決します。ベンダーは、彼らの側には何も悪いことはないと主張しています。

どちらの側（クライアントまたはサーバー）でも例外はスローされません-それは単に「スタック」しています。

Spring.Messaging.Nmsの使用を検討する必要がありますか？

間のメッセージングに JMS を使用したい一連のアプリケーションがあります。現在、すべてのアプリケーションが ActiveMQ ブローカーへの TCP 接続を確立しています。同じホスト上にある 15 程度のアプリケーションで inVM 接続を使用するか、共有メモリの形式を使用する一方で、そのホストから離れている残りの 20 程度のアプリケーションが引き続き TCP を使用することは可能ですか?

基本的には、inVM で構成されたブローカーと TCP で構成されたブローカーを組み合わせたいと考えています。それを行うことはできますか、それともブリッジ構成を行う必要がありますか?

私のプログラムの 1 つは、信頼できないネットワーク (つまり、インターネット) を介してログを記録するための信頼できる方法を必要とします。送信者または受信者はいつでもオフラインになる可能性があり、後で戻ることができます。ただし、クライアントから送信されたメッセージは見逃してはなりません。明らかに、syslog は法案に適合しません。syslog の代わりに Apache ActiveMQ のようなメッセージング サーバーの使用を検討しています。メッセージの送信者は perl、ruby、および c です。だから私はメッセージトランスポートとしてStompを持っています。

これは私の目的に役立ちますか？ここで見逃している落とし穴はありますか?

ラジ

ActiveMQ でパフォーマンス テストを実装しようとしているので、基本的なプロデューサーとコンシューマーをセットアップして、キューを介してメッセージを送受信します。問題なくプロデューサーを作成し、特定の数のメッセージをキューに書き込むようにしました。

これは問題なく完了し続けており、正しい数の保留中のメッセージがある管理者 Web サイトのチェックでこれを確認しました。

キューからメッセージを受信しようとすると、問題が発生します。単純なコンシューマーを使用してキューから読み取ると、キューからさまざまな数のメッセージが読み取られますが、メッセージの 1 つを受信しようとすると停止します。読み取るメッセージがまだキューにあることがわかりますが、クライアントはメッセージの 1 つを通過しません。メッセージを受信するための簡単な方法を使用しています。

一部のメッセージ（約20〜30）で機能しますが、ロックするだけです。メッセージ内の文字の一部がエスケープ文字である可能性があることが示唆されました (これはパフォーマンス テストであり、実際にはコンテンツを送信していないため、さまざまな長さのランダムな文字列を使用していました)。すべてのメッセージを変更しました。これは、文字「2」の繰り返しであり、まだ運がありません。ActiveMQ キューにアクセスするために必要なすべてのコンポーネントをロードするために Spring 構成を使用しており、キューはローカルホストで実行されています。