spring-integration-dsl

1熱

1答えて

こんにちは私はSpring Integrationを使用して次のフローを実装しようとしています。 RESTサービスを公開し、ペイロードを操作し、変更されたペイロードをJMSに書き込み、RESTサービスに応答します。 @Bean public IntegrationFlow httpInputFlow() { return IntegrationFlows .from(Ht

1熱

1答えて

JMS統合をSpring統合：再配信ポリシーとして再設計しようとしています

従来の設定ではActiveMQConnectionFactoryのConnectionFactory @Beanと、カスタム再配信をactiveMQConnectionFactory.setRedeliveryPolicy(..)で公開しています。私は、Spring Integration DSLは、ハンドル操作でもRequestHandlerRetryAdviceを使って再配信できることを知り

0熱

1答えて

スプリング統合dsl例外処理

.handleの内部で使用するメソッドから例外を処理するにはどうすればよいですか？以下のコードスニペットでは、processMessageメソッドは宣言に例外（public void processMessage（Message message）throws Exception）をスローし、連鎖の場合はdslでそれをどのように処理するのか不明ですか？ XMLの場合、XMLのように簡単なことは、ID

0熱

1答えて

JDK 7のJava DSLを介してSpring Integration Aggregatorを設定する

これは、Java 7でDSLを使用してSpring Integrationを初めて設定したときのことです.Lambda式はJava 8でのみ動作します。したがって、例Spring Integration Java DSLとSpring Integration Java DSL (pre Java 8): Line by line tutorialを参照してください。リモートRESTfulサービスに

1熱

1答えて

Spring統合DSLトランス

以下の問題については、を呼び出すことができます。入力オブジェクトをマップオブジェクトおよび呼び出しハンドラに変換するためにトランスフォーマを呼び出すと、その前に追加されたヘッダ値がハンドラにありません。ペイロードをマップオブジェクトに変換すると、すべてのヘッダーが失われるのはなぜですか？ //Adding header here setHeader("t", "t"); @Respo

0熱

1答えて

スプリング統合java dsl - java 7 - アウトバウンドチャネルアダプタでポーラーを設定

私のコードのいくつかをXMLからjava dslスタイル（pre-java8）に移行しようとしています。これは私が作成したJavaの設定です。私はポーラーの設定方法を理解することができません。この例ではグローバルポーラーについてしか話しませんが、私のケースではアダプター内にポーラーを設定する必要があります。 @Bean public MessageHandler kafkaMessag

0熱

1答えて

JMS、AMQPではなく、メッセージングの抽象化を扱うためのSpring Integration DSLには、どのような機能がありますか？

JMS（org.springframework.jms.*）の代わりにSpringメッセージング抽象化（org.springframework.messaging.*）のmessageDrivenChannelAdapter、listenerContainers ...のビルドファクトリがないようです。私はあなたがJmsMessagingTemplateを使用し、メッセージングのMappingJ

1熱

1答えて

例外フローの現在の相関IDを保持する新しいメッセージを案内する方法

スプリッタの後、メッセージを処理する際に例外が発生します。私はその例外を処理し、共通チャネルに、例外を生成したそのメッセージの相関IDとそのエラーを示す特別なヘッダーを持つ新しいメッセージを送りたいと思います。私はそれをこの方法を試した： @Bean public IntegrationFlow socialMediaErrorFlow() { return IntegrationF

1熱

1答えて

Spring統合におけるメッセージ集約ロジックのカスタマイズ方法Java DSL

統合フローでは、デフォルト戦略を使用した分割により、リストから項目が発行されます。その項目の処理が失敗することがあります。そのエラーを処理し、以前のメッセージ（カスタムエラーヘッダーに加えて）からのマッピング情報を持つ新しいメッセージを通常のメッセージングチャネルに送信します。アグリゲータでは、失敗したプロセスの数と失敗しなかったメッセージの結果を含む別のタイプのメッセージを生成するために、集約