問題タブ [jmstemplate]

org.springframework.jms.core.JmsTemplate は、defaultDestination..... を使用して 1 つのキューのみをサポートします。

インバウンドキューとアウトバウンドキューが異なる場合、どうすればよいですか?

ありがとう

Spring-JMSを使用しようとすると、コンパイルエラーが発生します。グーグルですばやく検索したところ、一致する結果は1つしか見つかりませんでしたが、有用な結果を得ることができませんでした。

私は次のコードを使用しています：

コンパイルしようとすると、次のコンパイルエラーが発生します。

と

私のコードのどこにもjavax.jms.Destinationを参照していません。そのエラーが発生する理由を知っている人はいますか？

私は ActiveMQ を JMS ブローカーおよびコンシューマーとして使用し、jmsTemplate を使用してメッセージを送信します。ピーク時には、毎秒約 100 件のメッセージがあります。

キューにメッセージがいくつあるかは関係ありませんが、メッセージが重複することがよくあります。私が思いついた一時的な解決策は、テーブルにインデックスを設定することです。現時点では、すべてのメッセージはデータベースにのみ保存されます。

私の最初の質問 - 非永続トピックを指定し、応答が必要ない場合、メッセージが複製されるのはなぜですか?

送信者:

リスナー：

春：

2 番目の質問は、jmsContainer の構成に関するものです。上のコードと下のコードの違いは何ですか? 上記のコードはトピックをサブスクライバーとして提供し、以下のコードはキューを提供します。

Camel とそのべき等なConsumer が重複の問題を解決すると思われることがわかりました。3 番目の質問は、Camel の構成に関するものです。私はこの構成を持っています（デフォルト）：

それはすべてのキューに適用されますか、それとも明示的なサブスクリプションを作成する必要がありますか? すべてのトピック/キューとすべての着信メッセージをチェックすると思います。現時点での問題は、すべてのメッセージに messageId=null があり、フィルターがそれをパラメーターとして受け取ることです。

messageId を設定する簡単な方法が見つかりませんでした。私の質問 - messageId を設定するだけで十分であり、例外として機能するか、構成に問題があります。たとえば、使用するトピックを指定する必要があります。

ありがとう、

ジダス

以下を理解するのに助けてください：

私はCachingConnectionFactory自分のアプリで使用しており、最初にjmsテスト中にそれを使用して、保証された配信、ロールバック/コミットなどのjms構成をテストしました。

JmsTemplate送信DefaultMessageListenerContainer時と配信時にSpringを使用しています。

1. 複数のテストメソッドを使用してシーケンシャルに実行する場合、これは難しい/不可能であることに気付きました。例：テストメソッドでは、AIがメッセージリスナー（コンシューマー側）で例外をスローし、再試行が発生します。次に、テストBが実行され、メソッドAIで別のテストが実行されますが、このテストを開始しても、テストAから再試行メッセージが表示されます。これは明らかに望ましくありません。テストの合間にjmxを介してキューをパージしますが、それでもこれらの再試行を受け取ります：（...検索してデバッグしました...パージが正しく行われたと確信している場合でも、なぜこれらの再試行が発生し続けるのか正確にはわかりません。たぶん、セッションのどこかにすでにキャッシュされていたのかもしれません...わかりません。

2. SingleConnectionFactoryテスト中に使用する必要があることがわかりました。この接続ファクトリを使用すると、再試行はなくなりますが、その理由はよくわかりません。なんで？（Spring refからの）接続を1つだけ使用していることを理解し、送信アクションごとにコンシューマーが削除されることに気付きましたが、これらの再試行で何が起こるかはよくわかりません：（...何か考えはありますか？（マルチスレッドの動作のためにデバッグが難しく、Web上でそれに関する適切な情報を見つけるのが困難です）また、CachingConnectionFactory 1つのセッションキャッシュサイズ1のみで使用しても、再試行の問題は解決しませんでした。

ありがとう

Spring TransactionSynchronizationManagerを使用しています。このマネージャーを使用して、新しいSynchronization TransactionSynchronizationAdapterを登録し、このTransactionSynchronizationAdapterのafterCompletion（int status）メソッドをオーバーライドします。 このafterCompletion内では、statusの値はcommited（0）として取得される必要がありますが、active（0）として取得されます。

これがコードの一部です::

引っ張る消費者を実装する必要があります。私が目にするほとんどの例は、プロデューサーがメッセージをコンシューマーにプッシュするものです。消費者が常に稼働していると仮定します。プロデューサーがメッセージをキューにプッシュし、コンシューマーがそれらのメッセージを独自のスケジュールで消費するようにします。私の消費者は営業時間外のカレンダーを持っており、営業時間外はリクエストを処理できません。

春にそれをどのように構成しますか。

ティア

ラグー

SpringsourceTool と Spring フレームワークを使用しています。

JmsTemplate経由でメッセージを送信するために使用するコードがいくつかありますconvertAndSend(Object)。JUnit テストとしてデバッグしたい。したがって、テスト クラスには、 を選択しますRun->Debug As->JUnit Test。

jmsTemplate.convertAndSend(obj)ブレークポイントを設定し、ヒットするまでトレースを綿密に追跡することができましStep Into (F5)た。

ありがとう！

Spring構成ファイルを使用して簡単なプログラムを実行しようとしています。構成では、JMSテンプレート用のBeanを作成しています。Eclipseから実行すると、すべてが完全に機能しますが、コマンドラインから実行しようとすると、次のエラーが発生します。

config.xmlクラスパスリソース[ ]でJMSTEMPLATEという名前のBeanを作成するときにエラーが発生しました：Beanのインスタンス化に失敗しました。ネストされた例外はjava.lang.NoClassDefFoundError：javax/jms/JMSException

なぜこれができるのか誰かが知っていますか？クラスパスを再確認しましたが、問題ありません。

BeanはBeanJmsTemplateとして宣言する必要がありますか？どちらのオプションも妥当だと思います。それは主にSpringがそのBeanをどのように実装したかという問題のようですが、ネット上での使用について矛盾するレポートを見つけ続けています。prototypesingleton

JMSTemplate.execute メソッドの本当の目的は誰でも説明できます。セッション コールバックを受け入れることができます。Spring ドキュメントには、それについての詳細は記載されていません。