spring-integration-dsl

1熱

1答えて

DSLを使用したSpring-integration-jdbc StoredProcOutboundGateway

DSLでspring-integration-jdbc StoredProcOutboundGatewayを設定した人はいますか？

1熱

1答えて

amazon sqsキューからのメッセージとそれまでの動作状態を消費するように統合フローを設定しようとしています。しかし、私は分や秒ごとにメッセージの数をペースしたいと思います。例えば毎分20メッセージ。ここでは私のSQLリスナーBean @Bean public MessageProducer mySqsMessageDrivenChannelAdapter() { Sq

0熱

1答えて

Spring統合：すべての発信エラーメッセージを調整する方法

例外としてスローされた場合でも非同期エラーとして処理された場合でも情報を漏らさないように、統合フローの呼び出し元に返されるすべてのエラーメッセージを調整する必要があります。。私はすべてのメッセージハンドラでカスタムエラーチャンネルを定義しないようにしたいと思います。私は成功せず、デフォルトのエラーチャネルに変圧器を添付しようとしている： @Bean IntegrationFlow error

0熱

1答えて

Spring統合を使用してrabbitmqからメッセージを消費するように最適化

アプリケーションコンテキスト間でイベントを渡すための統合フローを簡単に構築するために、IntegrationFlowFactoryを構築しようとしています。すべてが機能しているようで、イベントは非常に速く公開されています。しかし、私は消費がとても遅い理由を理解できません。 concurrentConsumersを追加したり、prefetchCountを変更しても何も変更されていないようです。

0熱

1答えて

Spring統合DSL両方のチャネルに同じメッセージ

同じメッセージ（ペイロード）を2つの異なるチャネルで処理する必要があるという要件があります。 PubliSHSubscribe Channelを使用すると、両方のチャンネルにメッセージのコピーを作成することで、私たちはそれに対処することができます。しかし、私たちは、各チャンネルが次々に実行されていると考えていました。そして、あるチャンネルのペイロードに何らかの変更を加えると、他のチャンネルのペイロ

1熱

1答えて

統合フローの条件付きハンドラ

私は、クライアントがミドルウェアを通って流れるメッセージを購読/購読解除し、メッセージのペイロードを指定のコールバックにポストすることで（指定された基準に従って）通知を受けることができるWebフック通知サービスを開発していますURL。メッセージ配信は次のようになります。あなたが見ることができるように flowBuilder .enrichHeaders(e->e.header(Mess

1熱

1答えて

バネ積分のxml構成で使用されるとき、「int」は何を意味しますか？

私は現在、春の統合のトピックで読んでいます。 Spring統合のXML構成で使用される表記法/接頭辞 - > "int"を使用しています。 <int:channel id="errorChannel"> <int:queue capacity="500"/> 誰もがそれを理解する上で私を助けることができますか？またどこかで私は 'si'が使われているのを見たことがある。これらのプレフィックス

0熱

1答えて

春の統合 - ファイル受信アダプター - id id

FileInboundChannelAdapterSpecのIDを設定する方法を知っている人はいますか？事前に Files.inboundAdapter(new File("etc")).nioLocker().preventDuplicates(); ありがとう：これは私がインバウンドアダプタを構築してい方法です。

1熱

1答えて

ダイレクトチャネルを使用したメッセージスプリッタの後のエラー処理

私はspring integration java dslを使用して電子メールを送信するサービスに取り組んでいます。私は電子メールに変換される個々のメッセージの集合に分割されたバッチメッセージを持っています。これらの個々のメッセージのいずれかでエラーが発生した場合、そのバッチ内の他のメッセージは処理されません。メッセージが例外をスローすると例外が正常に処理され、バッチ内の次のメッセージが処理

2熱

1答えて

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

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