Service ActivatorとPollerを使用してキューに複数のメッセージを送信する -- spring フィールド と transactions フィールド と integration フィールド と poller フィールド 関連 問題

Send multiple messages on a queue using service activator and poller












0
vote

問題

日本語

助けが必要です。

私のプロジェクトでは、トランザクションポーラーとともにSpring Integrationからサービス・アクティベーターを使用しています。このサービスは、トランザクションJMSTemplateも同様に一度だけインスタンス化します。ただし、ポーラーによって選択されたすべてのメッセージを1つのトランザクションだけで処理することを期待していました。これは何が起こっているのかわからない。メッセージがService Actribatorによって処理され、キューで送信されるたびに(1つのキューのみが使用されています)新しいトランザクションが開閉されます。これが遅いです。私はそれらをキューに送信したいです。コミュニティから助けが必要です。お願いします。事前にありがとうございました。

英語

Need help.

In my project, I am using a service activator from spring integration along with a transactional poller. The service instantiates only once a transactional jmsTemplate as well. However, I was expecting to have all the messages picked by the poller be processed within only one transaction. This is not what's happening. Every time a message is processed by the service activator and sent on the queue(only one queue is being used) a new transaction is opened and closed. This slow. I want to batch send them on queue. Need help from the community. Please. Thank you in advance.

</div
           

回答リスト


関連する質問

3  Spring JMS統合の間隔ベースのCronを設定します  ( Configure interval based cron in spring jms integration ) 
Queue1からQueue2へのメッセージを指定間隔で転送する必要がありますが、メッセージがQueue1に到着した直後だけではありません。以下は私の設定です。 <事前> <コード> <int-jms:inbound-channel-adapter id=...

0  Service ActivatorとPollerを使用してキューに複数のメッセージを送信する  ( Send multiple messages on a queue using service activator and poller ) 
助けが必要です。 私のプロジェクトでは、トランザクションポーラーとともにSpring Integrationからサービス・アクティベーターを使用しています。このサービスは、トランザクションJMSTemplateも同様に一度だけインスタンス化します。ただし、ポー...

0  ポーリングangular API呼び出しに関するコールバックに関する問題  ( Issue with callback on polling angular api call ) 
私は継続的にポーリングAPI要求を持っています。私はこれを助けるためにangular-pollerサービスを使っています。 <コード> var gamesPoller = poller.get(apiURL, { me...

0  Spring Integration Poller Spring Bootを使用したPoller XML構成  ( Spring integration poller xml configuration with spring boot ) 
スプリングブーツのプロジェクトに取り組んでいて、場所からファイルをポーリングするためのSpring Integration Pollerを追加し、そのファイルのスプリングバッチを実行して処理します。 これにスプリングバッチ統合を使用しました(以下の文書参照) ...

1  fixedDelay()とfixedrate()の違い  ( Difference between fixeddelay and fixedrate ) 
Spring integrations Pollers の Pollers.fixedDelay(5000) Pollers.fixedRate(5000) の違いは何ですか? ...

0  AngularJSは、Angular-Pollerの各ダニのパラメータを変更する必要があります  ( Angularjs need to vary a parameter for each tick of angular poller ) 
ここでangular-pollerデモをフォローしています: https://emmaguo.github.io/angular-poller/ 'greart'がnewtime argで呼び出されるように、動的なURLを構築するために引数を渡すことが...

0  SQSポーラーが1つのSQSポーラーになり、複数のSQSキューを処理し、それを優先しますか?  ( Can one sqs poller handle multiple sqs queues and prioritize it ) 
ユースケースがある場合は、2つのSQSキューがあり、それぞれがメッセージを取得しています。しかし、この状態は最初のキューにメッセージを取得している場合、2番目のキューからメッセージの読み込みを停止し、最初のキューメッセージを優先します。 SQS Pollerは...

5  Zeromq Poller vs Tornados EventLoop  ( Zeromq poller vs tornados eventloop ) 
デザイン賢明な設計と性能賢明なZeromqソケットの取り扱いにどのアプローチを推奨し、なぜですか? Zeromq Hogsが使用したTornadoのIOLOOPは、複数のソケットを処理するためのwhileループで使用されているポーラーよりもCPUが少ないこと...

5  LaravelとAjax Sporadic 401ポーラー内のエラー  ( Laravel and ajax sporadic 401 errors in a poller ) 
Laravel 5.0では、5秒ごとに実行されるAjax Pollerを使用してリアルタイムアップデートをシミュレートするオークションウェブサイトをコーディングしています。問題は、My ServerがSporadic HTTP 401のステータスを返すことで...

0  Pollerタスク実行者メモリリーク  ( Poller task executor memory leak ) 
私はエンタープライズアプリケーションを構築しており、アプリケーション間の内部通信にはActive MQを使用しています。 Poller AbstractPollingEndpointとErrorHandlingTaskeExecutorオブジェクトインスタンス...




© 2022 cndgn.com All Rights Reserved. Q&Aハウス 全著作権所有