問題タブ [spring-dsl]

Spring Integration DSL トランスフォーマーで使用される「カスタム」 ObjectMapper の構成に苦労しています。java.time.Instantオブジェクトのプロパティに解析したい json 表現を受け取りました。例:
{"type": "TEST", "source":"TEST", "timestamp":{"epochSecond": 1454503381, "nano": 335000000}}

メッセージは、質問を提起するカフカ メッセージです: カフカ メッセージを適切なオブジェクトに変換できるようにするために、カフカ エンコーダー/デコーダーを実装するカスタム シリアライザーを作成する必要がありますか、それともスプリング統合でこれを自動的に行う必要がありますか?

fw/依存関係とバージョン:
Spring Boot - 1.3.2.RELEASE
Spring Integration Java Dsl - 1.1.1.RELEASE
FasterXml Jackson - 2.6.5

Jackson のドキュメントに従って、この Java 構成をプロジェクトに追加しました: https://github.com/FasterXML/jackson-datatype-jsr310

また、次の Jackson JSR-310 アーティファクト:

Spring ブログのこの投稿に基づいて、新しい Java8 時間モジュールを登録する必要さえありません。 https://spring.io/blog/2014/12/02/latest-jackson-integration-improvements-in-spring#jackson-modules

これは私が得た例外です:

解決策:
問題は、Spring が jackson-datatype-jsr310 アーキタイプを検出し、JavaTimeModule を登録することを期待していたことですが、そうではなく、まったく問題ありません。これを修正する方法は 2 つあります
。 1. Spring Boot を Spring Integration でそのまま使用する場合の受け入れられた答え。
2. Spring Integration Dsl を使用する場合は、IntegrationConfiguration クラスを jsonObjectMapper() Bean とともに保持し、次のように使用します。

私はエンタープライズ統合パターンを使用して Spring Integration プロジェクトに取り組んでおり、MQ メッセージを消費し、何らかの処理を行ってから、それらを別のキューに書き込みます。

私の問題はこれと非常に似ているように見えますが、受け入れられた回答では解決されませんでした。

外部 Web サービスからの応答を受信した後、私の@Cacheable @Componentクラスは本文をArrayList. 次のエラーが表示されます。

これが、私が信じている問題のあるクラスです。

ご覧のとおり、パブリック getter メソッドを設定しようとしましたが、例外が引き続き発生します。

context.xml:

Spring Integration を使用して一連のファイルをバッチ処理しようとしています。メッセージをジョブに変換しようとするこの非常に古いxmlがあります

messageToJobTransformerメッセージをジョブに変換できるクラスです。問題は、このファイルがどこにあるのかわからないことと、xml 構成が必要なことです。純粋な Java DSL にしたい。これが私の簡単な設定です。

そして、これがゲートウェイの Bean です。

編集:バッチ構成クラスの更新。

したがって、期待どおりに動作し、機能するキャメルスプリングDSLのルートがいくつかあります。ただし、これらのルートを karaf にデプロイすると、動作が異なります。たとえば、1) <when><simple>${body} == null</simple></when>karaf で body が空であっても true と評価されるこの条件があります。

2) 条件 if(body != null) をチェックするプロセッサが 1 つあり、body が null でなくても true と評価されます。

他のすべての環境では問題なく動作するが、karaf では失敗する特定の理由はありますか。

ファイルをリモート SFTP サーバーに送信しようとしています。同じ工場と outboundFlow を作成しました。

UploaderSftpConnectionFactoryBuilder

}

ここで、統合テストを使用してアウトバウンド フローをテストしたいと考えています。そのために、testContextの下に作成しました：

TestContextConfiguration

@ https://github.com/spring-projects/spring-integration-java-dsl/blob/master/src/test/java/org/springframework/integration/dsl/testで提案されているように、偽の sftp サーバーも作成しました。 /sftp/TestSftpServer.java 以下は私の偽のサーバーです。

FakeSftpServer

最後に、以下は私のテストクラスです

TestConnectionFactory

このテストを実行すると、以下の例外が発生します。

私はそれを解決することができず、かなり長い間それに固執しています。私は spring-integration-dsl の初心者であり、どんな助けも本当に感謝しています。

ファイルを SFTP サーバーに送信したい。そのための送信フローを作成しました

以下のコードを使用して、このフローにメッセージを送信しようとしています。

以下のエラーが表示されます。

以下のように send メソッドにファイルを渡すと、すべてが魅力的に機能することに注意してください。

その原因が理解できません。これを解決するのを手伝ってください。

私には、これは可能な限り単純なスプリング統合の例のように見えます。si4demoから学ぼうとしています。しかし、実行すると、次の例外が発生します。

スレッド「メイン」org.springframework.messaging.MessageDeliveryException の例外: Dispatcher にチャネル「application.inbox」のサブスクライバーがありません。; ネストされた例外は org.springframework.integration.MessageDispatchingException: Dispatcher has nosubscriber です

どこが間違っていますか？定義されたフローは、受信トレイ チャネルへのサブスクリプションを作成しませんか?

メール（gmail）を受信するためにSpring Integration Java DSLを使用しようとしています。Redisも使用しています。メールを受信すると、 ConcurrentModificationException が発生します。検索中に、Kafka でも同じエラーが発生していることもわかりました。以下は私のコードと例外です。

助けてくれてありがとう。

例外 ：