問題タブ [spring-integration]

JMS (ActiveMQ) のみに接続された分散 Java システム (スケーラブルである必要があります ;-) ) を構築しています。Spring Integration を勉強しましたが、Spring Integration を使用するとどのような利点があるかわかりません。JavaService から別の JavaService などにメッセージのみを送信するため、Spring Core Project の JMS-Templeate を使用する方がよいと思います。

私はこのユースケースを持っています。

最初のチェーン:

これは相対コードです:

すべてがうまくいっています。

次に、別のチェーンがあります。

そして相対アクティベーター：

以下CensimentoClienteに説明するListペイロードには最初のチェーンのペイロードがあるため、スプリッターを使用してリストを分割し、最初のチェーンのコードを再利用します。

しかし、すべてのアクティベーターがトランザクション定義を取得するため (最初のアクティベーターは 2 番目のアクティベーターなしで存続できるため)、トランザクションが分離されているユースケースがあります。

目標は、2 つのチェーンのデータベース変更を同じトランザクションの一部にすることです。

何か助けはありますか？

よろしくマッシモ

私はSpring Integrationの初心者です.Spring Integrationを使用するという要件が1つあります

1. txt ファイルを読み取ります (ソース フォルダーから)
2. いくつかの検証を行います
3. 検証が成功した場合 - sucess ファイル (success フォルダー内) に書き込む
4. 検証が失敗した場合 - 失敗ファイルに書き込みます (エラー フォルダー内)。
5. ファイル形式が正しくない場合は、そのファイルをエラー フォルダーに移動する必要があることを意味します (例: 例外の列は 2 ですが、ファイルに含まれる列は 1 です)。

私の設定ファイルはこのようなものです

私のcheckFlatPackCVSParserWrapperクラスは

sampleFileFormat.xml は

そして、私の ErrorChannelWriter は

そして私の検証クラスは

そして私の ListToStringTransformer は

私のファイルには2つのフィールドではなく1つのフィールドが含まれています

ここでファイル形式が間違っているため、レコードはエラー フォルダーに移動されますが、エラー メッセージは表示されません。ファイル形式が正しくない場合にエラー メッセージ (TOO FEW COLUMNS WANTED: 2 GOT: 1) を追加するにはどうすればよいですか。私の要件は私のエラーファイルにあります

maya -TOO FEW COLUMNS WANTED: 2 GOT: 1 or(任意のエラー メッセージ)

解決策を教えてください

Visio で使用するための Spring スタイルの統合イメージがどこにあるか知っている人はいますか? ステンシルだけ、またはここに見られるように Spring Integration デザイナー GUI で使用されるイメージをダウンロードできる場所: http://blog.springsource.com/wp -content/uploads/2010/10/si-sts-editor.png

Visio http://eaipatterns.com/downloads.html用のこれらの EIP ステンシルがあります。

ただし、Spring Integration GUI で使用されているものを使用して、一貫性を保つことを望んでいました。

乾杯！

固定スレッドのJavaプログラムがあります。SpringIntegrationとActiveMQで実装されています。ここでの固定スレッドとは、プログラムに複数のスレッドがありますが、実行時のスレッド数は変わらないことを意味します。次に、接続プールのサイズを設定する必要があるので、次のことを知っておく必要があります。

1. スレッドの数
2. それらのどれが同時にDBに接続する可能性があります。

1.の場合visualVMツールを使用します。

• 2にvisualVMを使用できますか？どのように？
• この問題の別の解決策はありますか？

JMS エンドポイントを備えた SprintIntegration システムがあります。メッセージのサイズ制限は 4 MB です。それよりも大きな結果が得られました。SI にそれを複数のメッセージに分割させるにはどうすればよいですか?

/A

メール サーバーのインバウンド チャネルを備えた Spring アプリを使用している場合、すべてのメールのすべてのファイルを処理する最良の方法は何ですか (約 1 分ごとにポーリングし、複数の添付ファイルを含む 1 つのメールをフェッチします)。

受信チャネル (SimpleAsyncTaskExecutor または ThreadPoolTask​​Executor) でマルチスレッドを適用できますが、メールに 10 個のファイルが添付されている場合、それらの処理はほぼ 1 つのスレッドにバインドされるため、これはあまり役に立ちません。

すべてのメールのデータを集計し、すべてのファイルが処理された後に応答を送信したかったので、これまでかなり同期してきました。これももっと良い方法でできると思います。

一般に、すべての電子メールのすべてのファイルを非同期で処理し、再び非同期で電子メールの返信を作成するにはどうすればよいですか?

http アウトバウンド ゲートウェイのリクエストにカスタム ヘッダーとして渡したい Java オブジェクトがあります。以下はスニペットです

UserContext が Java オブジェクトになる場所

私が抱えている問題は、ヘッダー user_context がヘッダーにマップされていないことです。ログから、DefaultHttpHeaderMapper が Converter または ConversionService を要求していることがわかります。下記参照 -

どうすればいいですか？

ありがとう！

いくつか検索しましたが、サンプル/例が見つかりませんでした。

1 つのテーブル (入力) から地理座標を読み取り、処理して、座標に関連付けられた POI を生成するという要件があります。そのため、1 つの地理座標によって 1 つ以上の POI が生成され、別のテーブル (出力) に挿入する必要があります。

現在、JdbcCursorItemReader と JdbcBatchItemWriter を使用して、1 つの項目/レコードを読み取り、1 つの項目/レコードを書き込みます。指定された地理座標の POI を生成する ItemProcessor もあります。

カスタム JdbcBatchItemWriter はこれを達成するのに役立ちますか?

何か案は？ティア。

stompを使用してrubyスクリプトからActiveMQにXMLコンテンツを送信しています

以下に示すように、content-typeヘッダーをapplication / xml; charset=utf-8に明示的に設定しています

しかし、spring-integrationを使用してメッセージを読み取るJavaクライアントからメッセージを読み取ると、content-typeはtext/plainです。

その結果、unmarshallerが呼び出されると、例外を除いて解析が失敗します。

何が問題なのか