問題タブ [spring-integration]

チャネル アダプタを次のように定義しました。

次のように、実行時にポーリング レートを変更できないのはなぜでしょうか。

このソリューションをデバッグすると、アダプターにこの新しいトリガーが接続されていることがわかりますが、ポーリング レートは変更されていません (5 秒ごと)。同様の運で、アダプターの停止（）および開始（）も試みました。

誰でも私が間違っていることを指摘できますか? ありがとう

メッセージがQueue1に到着した直後ではなく、指定された間隔でQueue1からQueue2にメッセージを転送する必要があります。以下は私の設定です。

上記の xml 構成は、 <int:poller> 構成を無視して、キュー 1 からキュー 2 にメッセージをすぐに転送します。間隔ベースのソリューションと cron ベースのソリューションの両方を試しましたが、どちらも同様に機能するようです (キュー 1 からキュー 2 にメッセージをすぐに配信します)。ここで「ポーラー」の設定に何か問題がありますか? どんな助けでも大歓迎です。

SpringIntegrationベースのRestfulサービスをセットアップしようとしています。要求と応答のために個々のオブジェクトを作成することを避けようとしていますが、代わりにサービスでisUserAvailableForRegistrationなどの単純な関数にHashMapを使用しています。

例えば

以下は、統合関連のコンテキスト情報です。

HashMapをJSONに正常にマーシャリングできることをテストできますが、JSONデータをHashMapにマーシャリング解除するための構成がありません。

次の例外が発生します。

誰かが私に何が間違っている可能性があるかを理解するのを手伝ってもらえますか？

ヘッダーを再確認したので、HashMapへのアンマーシャリングの構成またはJacksonのサポートに問題があると確信しています。御時間ありがとうございます。

spring 統合 jms 受信チャネルで JMS ヘッダーを取得するにはどうすればよいですか? リファレンスに関する情報はあまり見つかりませんでした。

ありがとうございます。

ポート 30003 をリッスンする小さなプログラムがあります。これは、バイトストリーム データを次のように処理するサーバー クラスです。

これは問題なく動作しますが、Spring Integration の使用に移行したいと考えています。これは、同じことを達成するための私の tcp-context です。

Spring Integration アプローチを使用してプログラムを開始すると、次のスタック トレースが表示され、ソケット アドレスが既に使用されていることがわかります。

標準のソケット プログラムが正常に動作するのに、なぜ統合アプローチが失敗するのか理解できません。私のマシンには、30003 ポートでデータを利用できるようにするソフトウェアが少しあります。

お役に立てれば幸いです。

ありがとう

ActiveMQ トピックにメッセージを発行する必要がある春の統合パイプラインがあります。次の構成でde spring xmlファイルを構成しようとしています

ただし、メッセージはトピックに発行されません。JMS トピックにメッセージを発行するように春の統合を構成する方法を知っていますか? 私はあなたの答えを楽しみにしています。ありがとう、フローリン

RESTサービス呼び出しをPOSTして、返されるデータを取得する必要があります（これはすべてJSONを使用しています）。応答チャネルをチェーンとして持つアウトバウンドゲートウェイがあり、チェーンには1つのトランスフォーマーがあります。

ただし、トランスフォーマーを介してデバッグすると、返されるペイロードは単なるHttpStatusオブジェクトです。

多分私は何か間違ったことをしているのですか？どんな助けでも大歓迎です。ありがとう！

クライアントから送信されたメッセージをデータベースに永続化するためにSpring Integration 2.1を使用しています。

カスタム アダプタによって埋められるキューがあります。構成されたサービスアクティベーターは、このキューをポーリングし、Spring 管理の @Repository Bean にメッセージをリリースします。すべてのエラーはエラー チャネルにキャプチャされ、サービスによって処理されます。構成はこれまでのところ正常に機能します。

私の懸念は、データベースが利用できない場合、サービスアクティベーターがキューからのすべての着信メッセージをポーリングし、それらをエラーチャネルに入れることです。たとえばテストクエリを送信するなどして、データベースが明らかに利用できない場合に、サービスアクティベーターがメッセージをポーリングするのを防ぐ方法はありますか?

私の構成：

よろしく。

非同期プロトコルで送信する必要があるメッセージを含む永続的なトランザクション キューがあります。各メッセージは独自のトランザクションで送信する必要がありますが、特定の時間に処理中のメッセージの数が原因でthread-per-messageを使用できず、スループット要件により中間状態が持続することができません。

のコードを見ると、トランザクション リソースを に格納するJmsTransactionManagerを使用していることがわかります。そのため、単一のスレッド内で複数のトランザクションをどうにかしてシェパードするために を実装する必要があるようです。これは少し極端なようです...TransactionSynchronizationManagerThreadLocalPlatformTransactionManager

この複雑さを解消する Spring Integration ユニットの配置はありますか? 私はむしろJTA/XAの情報を見るべきですか？

以前、Spring アプリに XML ベースの構成を使用していました。

ここで、 @Bean、@Configuration などを使用した Java ベースのコンテナー構成のみを使用したいと考えています。

これら 2 つの XML 構成を Java ベースの構成に変換するにはどうすればよいですか?