問題タブ [activemq]

jetty-6.1.7を実行していて、JNDITemplateを介してSpring構成で参照したいActiveMQConnectionFactoryがあります。

私のjetty.xml構成はバニラです：

そして、春の設定でJNDIテンプレートに入れるのが正しいことを見つけることができません。

前もって感謝します！

OSX ヒョウに pyactivemq (リンク) をインストールしようとして苦労しています。コンパイルに関するチュートリアル (ポルトガル語) に従うと、問題なく終了しますが、テストを実行すると、crypt メッセージしか表示されません。

osx での pyactivemq の使用に関する Web 上の情報はあまりありませんが、私が見つけたのは、boost コンパイル時の間違ったリンクに関連するものです。

私は走っています：

• Mac OS 10.5.8
• Mac ポート 1.8.2
• 4 月 1.3.9
• Xcode 3.1.4
• Boost 1.41.0 (python 2.5 のインストール)
• Activemq-cpp 2.2.6
• pyactivemq 0.1.0

誰かがこれに関する情報を持っている場合はpython 2.5、macports からインストールしたものを使用していることを知っていると役立ちます

ActiveMQ と NMS を使用して相互に通信する C# パブリッシャーとサブスクライバーがあります。ActiveMQ がいつダウンするかを知る方法がないことを除いて、すべて正常に動作します。これは消費者にとって特に悪いことです。それらはデータの取得を停止しますが、データが表示されなくなるという事実を除けば、エラーやイベントは発生しません。

NMS (特に Apache.NMS.IConnection または Apache.NMS.ISession オブジェクト) を使用する方法はありますか

Spring から使用している実装をダウンロードしましたが、特定の Spring 実装は使用していません。使用しているものはすべて Apache.NMS および Apache.NMS.ActiveMQ 名前空間にあります。

WCF アプリケーションに Apache.NMS.WCF バインディングを使用しようとすると、次のエラーが発生します -

コントラクトには TwoWay (要求と応答または二重のいずれか) が必要ですが、バインディング 'NmsBinding' はそれをサポートしていないか、サポートするように適切に構成されていません。

私の system.service モデルは次のようになります -

Apache NMS をデュプレックスに設定する方法はありますか、それともサポートしていないだけですか?

埋め込み Camel ルーティングで、リモート JMS キューへの耐久性のあるコンシューマーがあります。マスター/スレーブ構成でこの種のルーティングを行うことは可能ですか? 現在、Camel ルートは、実際のフェイルオーバーが発生したときではなく、スレーブ ActiveMQ が開始されたときにすでに開始およびアクティブ化されているようです。

これにより、スレーブ インスタンスは、マスターにも送信される同じメッセージを受信するようになり、これにより、フェイルオーバー時に重複したメッセージがキューに到着します。

ActiveMQ 5.3 と Apache Camel 2.1 を使用しています。

ActiveMq で単純な pub/sub を実行しようとしています。私はそれをすべて正常に動作させることができますが、サブスクライバーは約 30 秒後に切断されます。変更できるタイムアウトの種類の値を探しましたが、何も機能していないようです。サブスクライバーは次のとおりです。

私はこれを試しました：

しかし、何も変わったようには見えませんでした。

問題を解決するには、プログラムを実行して約 30 秒間待ちます。ActiveMQ コンソールで接続が消えたことを確認できます (デフォルトではhttp://localhost:8161/admin/connections.jsp )。

何か案は？

C++ コンポーネントと Java コンポーネントの間で 2 つのプロセスで通信するメッセージ ブローカーとして ActiveMQ を使用したいと考えています。例えば。C++ コンポーネントがパブリッシャーで、Java コンポーネントがサブスクライバーです (複数のサブスクライバーが存在する場合もあります)。ActiveMQ Web サイトを見ると、ツール OpenWire と ActiveMQ-CPP について言及されています。ただし、Web サイトのすべての例では、生産者と消費者の両方に同じ言語を使用しています。

私の質問は次のとおりです。

1.ActiveMQ は異なる言語のプロデューサー/コンシューマーに対して機能しますか?

2.異なるプロセスで？どのように？

信頼できないインターネット接続上にあるローカル ActiveMQ ブローカーと、信頼できるデータセンターにリモート ActiveMQ ブローカーがあります。インターネット接続が利用可能になったときに送信メッセージがリモート ブローカーに送信されるように、「ストア アンド フォワード」セットアップを既に整理しました。それだけでもうまく機能しますが、メッセージがアウトバウンドの場合です。

しかし、今は逆のことをしなければなりません。シナリオは次のとおりです。

1. リモートActiveMQ ブローカーに新しいメッセージが表示されます。メッセージは特定のキューに入れられます。
2. 数分で、ローカルのActiveMQ ブローカーがインターネット接続を利用できるようになります。
3. その後、ローカルブローカはリモートブローカからメッセージを取得し、独自のローカル キューに配置できるようになります。
4. ローカルのコンシューマは、メッセージを見ることができます。

したがって、本質的には、ローカル ブローカーがリモート キューのサブスクライブされたコンシューマーになる必要があります。ActiveMQ のドキュメントを調べましたが、.xml 構成ファイルでこれを行う方法についてはまだ何も見つかりません。

これは私が探しているものですか？「ActiveMQ: JMSからJMSへのブリッジ」を参照してください。

アドバイスやヒントをいただければ幸いです。

SpringDefaultMessageListenerContainerのを使用してJMSメッセージを受信すると、2に設定しても、JMSメッセージが再配信されません。sessionAcknowledgeMode

RuntimeException私のJavaBean内の場合onMessage()、メッセージはJMSプロバイダー（ActiveMQ）内で確認応答されず、キューで保留中のままになります。ただし、再配信されることはありません。これは、Springが呼び出すことはないという事実が原因だと思います。これは、 ActiveMQのドキュメントsession.recover()によると、再配信を行うために必要です。

DefaultMessageListenerContainerRuntimeExceptionsの場合に呼び出すように構成する方法のヒントを教えてもらえますsession.recover()か？

よろしく、
マーティン