問題タブ [activemq-artemis]

私が抱えている問題が概念的なものなのか、設定ミスによる技術的なものなのかはわかりません。

目標は、アプリケーション コンテナ (具体的にはここでは WildFly) でホストされている Java EE アプリケーションと、すべて標準の JMS プロトコルとトピックを使用してスタンドアロンで実行されている Java SE アプリケーションの間で双方向のメッセージを送信することです。両方が同じブローカーと同じトピックを使用している限り、これは可能だと思います。

そのため、メッセージ ブローカーとして実行されている外部 Artemis インスタンスがあり、Java EE アプリケーションの個別の Bean でプロデューサーとコンシューマーを正常にセットアップしました。どちらも「topic1」という名前の同じトピックを使用しています。このプロデューサーによって送信されたメッセージは、コンシューマー Bean によって正常に受信されます。

これで、任意のコンテナーの外部でスタンドアロン アプリケーションとして実行される Java EE アプリケーションで、コンシューマーとプロデューサーの別のペアをセットアップしました。それらは同じブローカーに接続しており、同じトピック「topic1」を使用しています。また、このプロデューサーによって送信されたメッセージは、このコンシューマーによって受信されます。

プロデューサーのいずれかがメッセージを発行すると、両方のコンシューマーがそれらを受信することを期待していました。しかし、これら 2 つのアプリの間には何もありません。コンテナ内のアプリは、スタンドアロンのアプリからメッセージを受信して​​おらず、その逆もありません。ここで概念的な間違いを犯していますか、それとも構成に問題がありますか?

以前は OpenMQ を JMS プロバイダーとして使用していた Java サービス プログラムに取り組んでいますが、activemq-artemis を使用するように変換しています。

アルテミスから既存のトピック/キューのリストを取得する必要があります。これまでのところ、artemis に付属のサンプルと、Web で見つけた他のコード サンプルを組み合わせて開発した以下のコードがあります (try/catch アウトは省略します)。

デバッガーで各行をステップ実行すると、最後の requestor.request() メソッド呼び出しまで、コードが機能することがわかります。これが呼び出された後、スレッドのブラック ホールのようです。デバッガーは次の行に到達せず、catch ブロックは開始されず、artemis.log にはどのタイプのエラーも記録されません。putAttribute 呼び出しで文字列 queueNames を使用すると、同じ結果が得られます。

私のコードに問題がありますか、それとも何が起こっているのかについて誰かが私に洞察を与えることができますか?

追加の詳細: artemis サーバー 2.1.0 とクライアント コードは単一の開発マシン JDK7u65 でローカルに実行されており、テスト コードはこのプロジェクトの外部にあり、artemis との間で簡単なメッセージを発行および使用できます。

ありがとう。