問題タブ [jmstemplate]

私はキューを扱うのが初めてです。メッセージを正常に投稿して同期的に受信できますが、現在非同期にしようとしています。

sqs が提供する参照リンクは、jmsclient ラッパーの使用を提案しています。また、リンクには、jms クライアントに統合されたコードが既にある場合は、それを使用することも記載されています。

http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/jmsclient.html#samples

しかし、私はこの例を参照して、メッセージを同期的に送信および受信することを新たに始めています。

https://github.com/aws/aws-sdk-java/blob/master/src/samples/AmazonSimpleQueueService/SimpleQueueServiceSample.java

同じコードを使用してメッセージ リスナを実装することはできますか? コード例をいただければ幸いです。

以下のスプリング構成で jmsTemplate を使用しています [「*****」を使用して構造を隠しています]。

jmsTemplate がブローカーからの ack を待たないように、この構成で useAsyncSend=true を構成したいと考えています。JNDIでそれを行う方法がわかりません-最善の方法について誰か助けてもらえますか?

いくつかのコンテキストでは、jsr 準拠の実装を使用して、Spring バッチで JMS リーダーとライターを実行しています。Spring バッチが提供する JMSReader クラスと JMS ライター クラスを使用していますが、それらを独自のリーダーとライターでラップしています。JSR アプローチを使用しているため、一般的なアプリケーション コンテキストは利用できません。クラスは、ジョブ仕様または jsr 仕様に従って batch.xml を介して初期化されます。

私が遭遇した問題は、アクティブな mq の接続ファクトリを作成し、それを spring の JMSTemplate クラスのターゲット ファクトリとして設定する JMS リーダーおよび/または jms ライターを定義すると、スタンドアロンのバッチ アプリケーションがあることです。処理が正しくシャットダウンされません。IBM MQ の接続ファクトリーを使用する代替手段は正常に機能します。

私が行ったいくつかのコードを提供させてください。

これは、接続ファクトリーを作成する場所です。アプリが終了したときに、生きたままになっているスレッドを終了させるために行った変更のコメント行がいくつかあります。

ここで JMSTemplate オブジェクトを作成します

最後に、JMSReader の open メソッドを示します。ライターはほぼ同じです。

私が見ているスレッドは、接続といくつかの非アクティブ監視スレッドに関連しているようです。これらがそのまま存続することで、スタンドアロン アプリケーションがシャットダウンするのを防ぎます。

接続ファクトリまたはjmsテンプレートを構成してこれが発生しないようにする方法、またはリーダーが完了したらそれを管理して適切にシャットダウンする方法を知っている人はいますか?

JmsTemplate を Jboss 6.2 に統合しました。HornetQ はすべて正常に動作します。

私が追加しました

その後、次のメッセージが毎秒連続して表示されます

どうすればこれを止めることができますか?

データベース (Oracle) キュー テーブルをリッスンし、そのキューにレコードが配置されている場合にそれを処理する Java クラスがあります。UAT および開発環境では正常に動作しました。本番環境へのデプロイ時に、キューからレコードを読み取れない場合があります。レコードが挿入されると、それを検出できず、レコードはキューに残ります。これはめったに起こりませんが、起こります。統計を出すとしたら、1 日にキューに入れられた 30 件のレコードのうち、約 8 件が達成できません。レコードを読み取れるようにするには、アプリ全体を再起動する必要があります。

これが私のクラスのコードスニペットです..

ログから例外の痕跡が見つからないのは奇妙なことです。

誰でも助けることができますか？ちなみに、 receiveTimeout を 10 秒に設定しています

rdd.foreach メソッド内で Spring JMSTemplate クラスを使用しようとしていますが、Task Not Serializable エラーが発生しています。静的変数を試してみると、ローカルでは機能しましたが、クラスターでは、null ポインター例外が発生しています。

サンプルコード:

エラーログ：

誰も同じ種類の問題に直面していますか?

Tibco EMS との SSL 通信を確立しようとしています。TCP 通信が成功し、メッセージを発行できました。JMS テンプレートを使用して構成します。以下は、Tibco と通信するために私が持っているプロパティです。

これは、Spring で行われた JMS テンプレート セットアップのコードです。

このリンクを読んで、指定されたパスに.pemキーと証明書があるサーバーマシンにキーが存在するかどうかを確認しました。ssl_server_identity = machineName.crt.pem ssl_server_key = machineName.key.pem

EM メッセージを発行しようとしたときに表示されるエラーは次のとおりです。

Weblogic はサーバーです。SSL 通信用に weblogic で何か設定する必要がありますか?

通信を確立するために weblogic サーバーに追加のパラメーターを追加する必要があるかどうかを提案してください。また、POM で使用している tibco の依存関係は次のとおりです。

以下は、スプリング ブートでの Hornetq 構成です。

これが私のプロデューサーです

これが私の消費者です

ここに私の設定ファイルがあります

@JMSlistener の消費プロセスを遅くしたいのですが、JMS リスナーが常にキューにヒットしたくありません。