問題タブ [jmstemplate]

jms テンプレートで単一のキューのコンシューマーの数を構成したいと考えています。私はこれを実装しようとしました: JmsTemplate - キューごとに同時実行を定義しますか? しかし、ActiveMQQueue には 1 が表示されます。私のメッセージング コンテキスト:

別の関連する質問:「リスナー」と「messageListener」プロパティに違いはありますか?

私は ActiveMQ をメッセージ ブローカーとして使用しており、コンシューマーによって処理される入力ストリームとして大きなドキュメントを送信するという JMS 要件があります。私が抱えている問題は、Spring の org.springframework.jms.connection.CachingConnectionFactory を使用して ActiveMQConnectionFactory をラップする場合、セッション オブジェクト (javax.jms.Session) を org.apache.activemq.ActiveMQSession にキャストする必要があることです。ここで提案されたものです（BlobMessage を使用して Active MQ を使用してファイルを送信する）。

次に、一般的な Session オブジェクトを ActiveMQSession にキャストすると、例外が発生します。Spring は javax.jms.Session のプロキシのみを提供し、プロキシ先のターゲット オブジェクト (つまり、org.apache.activemq.ActiveMQSession) は提供しないためです。したがって、私が頼った解決策は、CachingConnectionFactory を使用する代わりに、単純な ActiveMQConnectionFactory を使用することでした。以下のサンプル コードから ClassCastException を取得せずに CachingConnectionFactory を保持する方法はありますか?

そして、ClassCastException がスローされないようにするアプリケーション コンテキストに現在あるものを次に示します。コメント付きのブロックも参照してください。これは、例外をスローする古い構成を示しています。

DMLC と JMSTemplate のトランザクションに関していくつか質問があります。

1. トランザクションを使用していない場合、Spring DMLC はコールバックを使用してメッセージを非同期に受信しますか?

2. DMLC は、トランザクション セッションの使用中にメッセージを非同期で受信しますか。(sessionTransacted を true に設定します)。sessionTransacted を true に設定した後の動作は何ですか?

3、消費者の見通しからのAUTO_ACKとSESSION_TRANSACTEDモードの違いは何ですか。AUTO_ACK モードでは、DMLC はメッセージの受信後に承認をブローカーに送信します。同様に、SESSION_TRANSACTED モードでは、DMLC は各メッセージを受信した後にコミットします。パフォーマンスの点でどちらがより良い方法で、違いは何ですか?

4 JMSTemplate メッセージの送信は常に同期的ですか。非永続的なメッセージをトピックに送信している場合でも?

ありがとう、アヌジ

Oracleを使用するように構成されたactivemq jdbcPersistenceAdapterがあります。プライマリ ブローカはロックを取得しますが、キューにメッセージを送信すると、データベース テーブルにメッセージが表示されません。プロデューサーがなくなるまでメッセージが消費されないため、メッセージをキャッシュしたくありません(長い話)。

春の DefaultMessageListenerContainer を停止してから、後でもう一度開始する必要があるシナリオがあります。10 の異なるキューをリッスンする 10 の異なる DefaultMessageListenerContainer があります。10 個の異なるコンテナーすべてが、同じメッセージ リスナー クラスの同じメソッドを呼び出しています。onMessage メソッドで取得した例外に応じて、特定のキューの messagelistenercontainer を停止したいと考えています。上記のシナリオを達成する方法を教えてください。

以下は私のリスナーの設定です

メッセージをキューに配信した後、ガベージコレクションが行われず、キープアライブしていないようJMSProducerです。私はSpring 3.2.2を使用しており、CachingConnectionFactoryメッセージを送信するためにキープアライブ設定を使用しています。

メッセージを送信するたびにプロデューサーの数が増え続けます。

私が使用している春のバージョンに関連していますか？
または、構成で何か間違ったことをしていますか?

JMS Destination からメッセージを読み取り、Chuck Tasklet を使用して XML ファイルに書き込むように構成されたバッチ ジョブがあります。JMS リーダーは、JMSTemplate の receive メソッドを呼び出すカスタム実装です。JMS Broker として webMethods Broker を使用しています。バッチの実行中に、Broker Destination からのメッセージの読み取り中に作成された Consumer セッションが、バッチの完了時に破棄されていないことが確認されました。それらは、JVM をシャットダウンした後にのみ破棄されます。以下に詳細を記載しましたが、

JMS Spring XML 構成:

実際の問題を指摘する上での助けは素晴らしいでしょう。

@Autowiredを使用して JmsTemplate オブジェクトをクラスに挿入しようとしていますが、メッセージを送信しようとするたびにNullPointerExceptionが発生します。アプリケーション クラスでは、 ApplicationContextを使用して jmsTemplate をインスタンス化できます。

コンテキスト オブジェクトを取得する方法がわからなかったため、他のクラスではこれを行うことができませんでした。

これは私のアプリケーションクラスです:

これは Producer クラスです。

これは完全なスタック トレースです。

ここで何が欠けていますか？