spring-dsl

0熱

1答えて

は、JAVAのDSLを使用してラクダとの統合アプリケーションを開発しようとしていますが、私は私の接続ヘルパーをautowireしようとすると、私はここで、null値を取得するコードです： import com.example.helperproject.ConnectionHelper; @Singleton @Startup @ComponentScan(basePackages =

2熱

1答えて

Spring統合中期フロートランザクションを追加するDSL

トランザクションの特定の部分をトランザクションとして作成したいと考えています。たとえば、最初の2つの変換演算をの1つをトランザクションブロックにしたいとします。ここで私が使用してフローコードは次のとおりです。 @Bean public IntegrationFlow createNumberRange() { return IntegrationFlows.from("npEvent

0熱

1答えて

Spring Integration - ActiveMQ to Kafka

現在、ActiveMQからのメッセージを消費し、それをKafkaに公開するアダプタを作成しようとしています。私はこれらの2つのメッセージングシステムを統合するためにバネ統合を使用することを考えています。私の問題は、私のアプリケーションでは、多くのアプリケーションがレコードをactiveMQに公開するモデルのレジストリを維持しないということです。これらのjavax jmsメッセージを受け取って、

1熱

1答えて

DSLを使用してspringcloudstreamでファイルのヘッダー行（1行目）をスキップするにはどうすればよいですか？

私はSpringクラウドストリームを使用してファイルを読み取り、ファイルスプリッタを使用して分割し、DSLスタイルを使用してメッセージとして各行を出力します。ファイルにはヘッダー行があり、ヘッダー行をスキップする簡単な方法があるかどうか疑問です読書の前/後。何か助けていただければ幸いです。 https://github.com/spring-cloud-stream-app-starters/f

0熱

1答えて

春の相関IDの設定方法DSL

Spring DSLでの相関IDの設定方法は？以下のコードは、Active MQに相関IDを反映 <setHeader headerName="correlationId"> <constant>IFS123</constant> </setHeader> が <setHeader headerName="JMSCorrelationId"> <constant>IFS4

0熱

1答えて

Spring DSLを使用したCamelカスタム@Converterに関する問題

私はちょうどカスタムコンバータを学びたいと思って問題に遭遇しました。どんな助けでも大歓迎です。キャメルバージョン2.17とJBossヒューズ6.3私の春のDSLで @Converter public class MyConvertor{ public MyConvertor(){} @Converter public static String convertT

1熱

1答えて

春の統合DSL JmsMessageDrivenChannelAdapter無限の再試行

背景：私たちは、下図のように春のXML設定ファイルに記述された春の統合アダプタを持っています。エラー処理のすべてのシナリオで完璧に動作しています。すべてのことは、エラー処理はエラーメッセージをキューに書き込むことです。今度は、このXML設定をDSLに変換する必要があります。これを以下のコードを使用して変更しました。問題：エラーが「inputChannel」チェーンの内部で起こるたび、我々はい

1熱

1答えて

tikaを使用しているApache camel

tikaの例をで検索しようとしています。spring DSLを使用しています。私はtikaコネクタが利用できますが、spring DSLを使用した例はありません。私はhttps://github.com/apache/camel/tree/master/examples#examplesのリンクを含むすべての場所を見ましたが、これまでの運はありません。私はそれに助けてください。例として使用する

1熱

2答えて

チェーン内の各ハンドラに異なるエラーハンドラを割り当てる

私はアプリケーションに、ある機能を実行するために特定の順序でサービスチェーンを呼び出す必要がある単純なフローを指定しています。 Springの統合とそのDSLはこのシナリオに適しているようです。これらの個々のサービスのいずれかがチェーンを停止すべきその時点で、（これらのサービスは、外部アプリケーションへの呼び出しです）も失敗することもできます。これだけでなく、障害の発生したサービスに応じて、制御

0熱

1答えて

Springインテグレーション "Publish Subscribe Channel" with Spring DSL

私のフローが始まる単純なフローを構築しようとしていますが、HTTP受信リクエストをHTTP受信リクエストで受信し、それを 'SubscribableChannel'に公開します。このチャンネルを購読しているユーザーは「N」人になる可能性があります。下の図はフローを示しています。私はこの流れを設定するには、春のDSLを使用しようとしていますし、それがうまくなってトラブルを抱えています。以下は私のコ