GlassFishのRabbitMQベースのメッセージ駆動型Bean

Question

私は、コンポーネントのメッセージングソリューションとしてRabbitMQを使用するシステムを構築しています。しかし、私はEJBとしてGlassFishアプリケーションサーバー上でディスクIO集中型タスクを実行するいくつかの従来のEJB Javaコードを持っています。私はそのコードを書き直したくないので、そのコードとやりとりする方法を見つけたいと思います。私はただRabbitMQ Javaクライアントを使うことができると知っていますが、どのようにメッセージ抑制に対処するのか分かりませんが、4つのタスクが同じ時間に実行されているというだけではなく、メッセージ駆動型GlassFishのBean。

私が思いついた唯一の事は、PostConstructでタイマーを開始するシングルトンEJBで、そのタイマーがAMQPクライアントの受信ループをブロックすることになります。受信したAMQPメッセージをローカルのGlassFish JMSプロバイダにコピーしてMDBでポーリングすることもできますが、これを気に入らないのは、いくつかのGlassFish JMSプロバイダを監視して、状況を確認する必要があるからですRabbitMQ。

私はAMQPとJMSを相互接続する方法に関する情報を見つけるのに苦労しています。任意のアイデアが評価されます。

Answer 1

これを書いてみましょう：これは、GlassFish用のMDB互換AMQPコネクタはありません。

Answer 2

基本的に異なる概念であるため、AMQPとJMSは相互に接続できません。 AMQPは、データがワイヤ上でどのように見えるか、およびブローカが動作する方法を定義する標準です。JMSはAPIの定義です。

AMQPブローカの実装ではJMS APIを提供できますが、RabbitMQには既にこの機能が備わっていると思います。