問題タブ [spring-jms]

Spring Batch での JMS Item Writer/Reader の使用法を詳細に (Spring Batch のドキュメントよりも) よく調べるための優れたリソースを知っている人はいますか?

具体的には、キューを介して唯一のインターフェイスが非同期である既存のシステムを再利用しようとする任務を負っているため、次のことが可能かどうか疑問に思っています。

ステップ 1: いくつかのデータを読み取り、メッセージを作成します。
ステップ 2: JMSItemWriter を使用してメッセージをキューにドロップします。
ステップ 3: 応答キューで JMSItemReader を使用して、メッセージが戻ってくるのを待ちます。
ステップ 4: 他のことをし
ます... 1 日に数千回、すすぎと繰り返しを行います。

つまり、基本的に Spring Batch を使用して、非同期リソースとの同期対話を強制します。研究を進める前に、これが A) 可能であり、B) 将来大きな頭痛の種となるフレームワークの恥知らずな乱用ではないことを確認したいと思います。

事前に情報をありがとう。

Springによって設定されたJBoss5.1の下にJMSメッセージリスナーがあります。ThreadPoolTask​​Executorはコアプールサイズが15になるように構成されていますが、要求を処理しているスレッドは1つだけで、他のスレッドは待機していることがわかります。ThreadPoolExecutor APIによると、制限されたキューが必要ですが、Springでどのようにそれができるのかわかりません。

構成は次のとおりです。

14個の待機中のスレッドのスタックトレースは次のとおりです。

これは、 1つのスレッドのみを実行しているSpring ThreadPoolTask​​Executorに似ている可能性がありますが、私の場合、コアプールのサイズが1より大きいことに注意してください。

Spring FrameworkJdbcDaoSupportには、 を必要として内部でDataSourceを作成するクラスがあるのに、JMSを必要として を作成する類似のクラスがないのはなぜですか?JdbcTemplateJmsSupport ConnectionFactoryJmsTemplate

私が理解しているように、クラスの目的は、アプリケーション コンテキストで(インスタンスごとに 1 つ)JdbcDaoSupportの冗長なインスタンスを排除することです。代わりに、コンテナーはアプリケーション DAO のインスタンスを作成します。それぞれが から派生し、一意のものを受け取り、これを親インスタンスに提供します。親インスタンスはそれを内部の に提供します。JdbcTemplateDataSourceJdbcDaoSupportDataSourceDataSourceJdbcDaoSupportJmsTemplate

Springが、アプリケーション コンテキスト内のインスタンスJmsSupport数を減らすのに役立つ類似のクラスを提供しないのはなぜですか?JmsTemplate

キューの ActiveMQ で redeliveryPolicy を設定するにはどうすればよいですか?

1）ドキュメントでは、次を参照してください：activeMQ Redelivery、 ConnectionFactory または Connection で設定する必要があることを説明しています。しかし、キューごとに異なる値を使用したいと考えています。

2)それとは別に、私はそれがうまくいかないようです。このようにSpringの接続ファクトリに設定しても（Spring 3.0でactivemq 5.4.2を使用しています）、効果がないようです：

また、定義されたキューのプロパティとして設定しようとしましたが、定義された値よりも早く再配信が行われるため、無視されているようです:

ありがとう

Spring 2.5.6 でより多くの jmsTransactionManagers を実装しようとしていますが、うまくいきません。

5 つの異なる環境から読み書きする必要があるため、5 つの接続ファクトリを取得しました。それらはすべてキュー xml Bean にありますが、1 つのキューからメッセージを読み取り、それらがオプションに適合しないため、トランザクション マネージャーでロールバックを行います。

私の質問は、どうすればより多くの JmsTransactionManagers を構成できるかということです。

topATopic をリッスンする 5 つのスレッドのプールを達成することを目標に、JMS サブスクライバー リスナーを次のように設定していますが、実行時に複数のコンシューマーが同じレコードを処理していることがわかります (recordCount*コンシューマーの数)。

私は春が初めてなので、何か間違ったことをしていると思います。

誰かが私の目標を達成する方向に私を向けることができますか?

だから私は次の出版社を持っています：

そのため、Bean 宣言の設定に行き詰まっています。JMSTemplate が必要なのはわかっています。

しかし、接続ファクトリーまたは宛先を設定する方法がわかりません。春のドキュメントには例さえありません。

だからここに私の問題があります！

認証付きの Tibco EMS トピックがあります

これからメッセージを公開して消費したいスタンドアロンアプリがあります

そして、Springs JMSTemplate、Listener などを通じてこれを行いたいと思います。

リスナーの例:

}

サンプル発行元:

パブリック クラス ExampleProducer {

プライベート JmsTemplate jmsTemplate;

}

jms.jndi.initialContextFactory=com.tibco.tibjms.naming.TibjmsInitialContextFactory jms.jndi.urlPkgs=com.tibco.tibjms.naming

jms.jndi.providerUrl=tibjmsnaming:/ * ***.net: ***

これは可能ですか？

ありがとう