apache-camel

0熱

1答えて

私はApache Camelを使用して、sftpを使用してサーバーからファイルを取得しています。私のコードは SFTPから受信している：//example.com：？22/DEV139 /アップロード/アラモユーザ名=管理&パスワード=管理&バイナリ=真&切断=真& =真それは可能削除しますログにファイルの内容が表示されるので、このディレクトリからファイルを正常に取得できますが、次の例外がスロー

3熱

2答えて

RecipientlistとRouting Slipの相違点EIP

Apache Camelの新機能で、さまざまなEIPを理解しようとしています。かなりの例を見ました。 EIPの両方の受信者に複数の受信者にメッセージを送信する必要がある場合、これらはヘッダーに設定されています。その後、彼らの違いは何ですか？

1熱

1答えて

差分パーティションキーとApache Camelのキー

私はcamel-kafkaバージョン2.19.2を使用しています。この質問を投稿する前にCamelsのウェブサイト - camel-kafkaのドキュメントを調べました。メッセージを生成するための次の例があることがわかりました。 Producing messages: from("direct:start").process(new Processor() { @Overri

0熱

3答えて

春のブートキャメルテスト

私は春のブートを使用してキャメルのテストを書いています。以下は、私はラクダを開始すべきではありません期待してテストクラス @RunWith(CamelSpringBootRunner.class) @SpringBootApplication @ComponentScan(basePackages = ["example.test"]) @UseAdviceWith @Bootstrap

1熱

1答えて

CamelContextがPooledConnectionFactoryの初期化中にシャットダウンしています

ActiveMQComponentをcamel cdiでorg.apache.activemq.pool.PooledConnectionFactorを使用して初期化しようとしています。 ActiveMQConnectionFactoryでは、正常に動作しています。ログをいくつか追加しましたが、PooledConnectionFactory、CamelContextがシャットダウンしているときに

2熱

1答えて

fail-fast apacheラクダユニットテスト

apache camelの "fail fast"ユニットテストを作成できますか？私はラクダユニットテストでMockEndpointを使用していますが、メッセージ数などのいくつかの期待を提供しています。そしてassertIsに耳を傾けてください。満足しています。これは成功またはタイムアウトまで待機するため、交換が失敗した場合、テストは期間を延長するタイムアウトを待ちます。ほとんどのテストでは、

0熱

1答えて

キャメルルートポリシーとは何ですか？

私は初めてApache camelを勉強しています。ルートの障害を処理するには、cJavaDSLProcessorコンポーネントのcFileコンポーネントの後にコードスニペットがあります。 .handleFault().routePolicy(15).threads(10).maxPoolSize(20) 低レベルの説明とその背後にある目的についてここで何が起こっているのかよく分かりますか？

0熱

1答えて

プロセッサにBeanを挿入する

@BeanInjectをプロセッサに使用しようとしていますが、常にnullです。 RouteBuilderでBeanにアクセスできます。また、ProcessorクラスがRouteBuilderに定義されている場合はProcessorにもアクセスできますが、Processorクラスがそれ自身のファイルにない場合はアクセスできます。これはサポートされていませんか、何か不足していますか？ [更新] 私

1熱

1答えて

アグリゲータの柔軟な時間基準completitionPredicate

Aggregator2コンポーネントに問題があります。私は、受信メッセージを式プロパティ付きのリストに結合する集計戦略を使用して、一緒に結合されるメッセージを決定する日付フィールドを指定します。メッセージをいつフラッシュするかを決定するために、いくつかのcron式と日付フィールドを使用するcompletitionPredicateが必要です。問題は、メッセージが到着したときにcompletit

1熱

1答えて

Apache Camel ElasticsearchでGETリクエストを使用中に例外が発生する

説明： Apache Camelを使用して、Elasticsearch 5.4から特定のフィールドを読み取る必要があります。エラーXContentのうち建物のtoString：com.fasterxml.jackson.core.JsonGenerationException：フィールド名を期待して、オブジェクトを起動することはできません、私は以下のコードを使用すると、私は応答に例外を表示するこ