問題タブ [spring-dsl]

Java だけでなく XML ベースの DSL にも Apache Camel の静的コード分析を実装しようとしています。利用可能な SCA ツールはありますか?

以下のコードで例外が発生し続けます。

org.springframework.integration.MessageDispatchingException: Dispatcher にサブスクライバーがありません

誰でもこれについて助けることができますか

フル スタック トレース

このエンドポイントにアクセスして、メッセージを topicChannel に送信します。

コントローラ

サービス

Spring Integration Java DSL で WSInboundGateway を使用する場合、ヘッダー (その値) を抽出し、それを使用してたとえば Enum を設定する方法はありますか?

私はこれを試しましたが、SpEL は評価しません:

私は次の設定を持っています

チャネル 3 は pub-sub チャネルであり、メッセージを処理し、完了後に aggregatorInputChannel にメッセージを入れる 2 つのコンシューマーがあります。ただし、私が観察しているのは、メッセージが最終的に aggregatorOutputChannel に入れられたとしても (アグリゲーター Bean 定義を介してデバッグし、メッセージが aggregatorOutputChannel に入るのを見ることができます)、channel3 のゲートウェイがブロックされ、返されないことです。その結果、メッセージはチャネル 4 には送信されません。

ここで何か不足していますか？それとも何か間違ったことをしていますか？

AggregationMessageGroupProcessor は、aggregationPayloads メソッドをオーバーライドするだけのカスタム アグリゲーターです。

ありがとう！

Spring DSL を使用したルーティングのためにラクダを試しています。宛先にメッセージを取得できません。私は何かが欠けていることを知っています。問題を理解するのを手伝ってください。以下のように deviceMessageRouteIdentifier にヘッダーを設定しました

私のキャメルルートはここにあります

deviceMessageRouteIdentifier に到達できますが、宛先 gen2BridgeProcessor に到達できません

前もって感謝します

次の例を適応させようとしています: https://github.com/joshlong/spring-and-kafka

次のライブラリの最新の安定したバージョン:

統合 DSL ライブラリは、おそらく新しい KafkaProducer の導入によって引き起こされたリファクタリングを経たようです。

私のプロデューサー設定のコードは次のとおりです。

メッセージ生成のコード:

それは私が得る例外です:

更新:
完全な作業ソースは私のフォークにあります:
https://github.com/magiccrafter/spring-and-kafka

Spring Boot と Integration DSL を使用して、メッセージを HTTP Post として残りのサービスに送信したいと考えています。（基本）認証でこれを行う方法の例はありますか？

他のすべては正常に機能しているようです。ログには「org.springframework.web.client.HttpClientErrorException: 401 Unauthorized」と表示されます。