問題タブ [camel-ftp]

私はおそらく何かを見逃していますが、ここで何が起こっていますか。

これは機能します。todoフォルダーに 2 つのファイルがあります。このルートを作成すると、すべて正常に動作し、30 秒ごとに 2 つの交換 (ファイルごとに 1 つずつ) を受け取りました。

問題:しかし、このルートを作成すると、30 秒ごとに 1 つの交換が受信され、2 つのファイルが切り替わります。

baseFtpConnectionString の ftp URL は、String.format の後に次のようになります。

pollEnrich が 2 つの取引所を送信しないのはなぜですか? from ステートメントと同じ動作をすることは想定されていませんでしたか?

編集1

poolEnrich(両方のファイルのすべての交換を受け取る)を使用してそれを行う方法はありますか?

編集2

どうやらありません。では、リンク上のもの以外に、コンポーネントftpで開始されたコンポーネントからすべてのファイルをロードする他の方法はありますか?direct

時々実行する必要があるこの同期パイプラインがあります（30分ごとに言ってみましょう）：

1. ftp に接続します。
2. フォルダー A から.jsonファイル (単一ファイル)を読み取ります。
3. ファイルの内容をアンマーシャリングし ( Class A)、ルート コンテキストに追加します。
4. フォルダー B からすべての.fixedlengthファイル (複数のファイル) を読み取ります (preMove: processingFolder、move: doneFolder、moveFailed: errorFolder);
5. ファイルの内容をアンマーシャリングし ( Class B)、いくつかのロジックを実行します。
6. フォルダー C からすべての.xmlファイル (複数のファイル) を読み取ります (preMove: processingFolder、move: doneFolder、moveFailed: errorFolder);
7. ファイルの内容をアンマーシャリングし ( Class C)、いくつかのロジックを実行します。
8. ルートを終了します。

これは、Java DSL で作成された単一のパイプラインです。エラーが発生した場合、プロセスは停止します。これを作成するためにキャメルに本当に苦労しています。可能ですか、これを手動で処理する必要がありますか? いくつかのデモを作成しましたが、適切に動作するものはありません。

どんな助けでも大歓迎です。

スタンドアロンのキャメル ルートを実行しています。Eclipse-> Run-As-> Java Application で Main.class を実行すると、正常に動作します。ファイルが消費され、すべてのルートが機能します。

私のec2マシンでgit-cloneを実行mvn package -> mvn exec:javaして同じプロジェクトを実行すると、正常に実行されますが、ファイルをダウンロードせずにFTPエンドポイントにpingするだけです。

依存関係のjarファイル（ec2内）のすべてのjarをチェックしましたが、Eclipseのmaven-dependencies（ローカル）と同じです

私のポンは次のようになります：

これを次のようなApache Camelルート呼び出しに変更する必要があります:-

主な質問は、この requestBodyAndHeaders でユーザー名とパスワードを渡す方法です。ヘッダーを通過しようとしました (ヘッダーはマップ、キーと値のペア)

pollStrategy が定義され、レジストリに追加されたコンシューマ エンドポイントとして ftp uri を持つ標準ルートがあります。ただし、次のエラーが発生します。

さまざまな組み合わせを試しましたが、常にこのエラーが発生します。誰かが私が欠けているものを見つけることができますか? 私のコードは、私が見た Camel 単体テストとかなり似ているようです。ルートは次のようになります。

uri の pollStrategy 参照を削除すると、すべてが機能することに注意してください。

私の使用例は、新しいファイルのリストを定期的にローカル ディレクトリにポーリングし、それらを 1 つの接続で FTP サーバーにアップロードすることです。Camel ルートは、Spring XML で次のように定義されています。

ルートは正常に機能していますが、FTP サーバーが接続をタイムアウトするまで FTP 接続が接続されたままになります。同じ接続を再利用してファイルのバッチをアップロードし、バッチ内の最後のファイルのアップロードが完了したらすぐに接続を閉じたいと考えています。Camelでこれをどのように達成できますか?

FTP の場所からバッチごとにファイルをダウンロードするルートを開発しています。私のルートの下に見つけてください -

ルートは正常に機能し、すべてのファイルがダウンロードされます。しかし、バッチの詳細 (つまり、CamelFileBatchIndex と CamelFileBatchSize) はログに記録されません。

以下の出力を見つけてください -

Web サービスと FTP から特定の場所にファイルを生成する必要があります。

ルート1:

ルート 2: FTP ルート

ルートを開始するには

上記のコードは、FTP ルートで場所をハードコーディングしたときに機能しました。これらの 2 つのルートをパイプライン処理し、Route 1 (「ファイル名」) の出力を FTP の Route2 に渡すにはどうすればよいですか?