問題タブ [akka-camel]

次の例 ( Akka Camel docから取得) では、Jetty HTTP コンポーネントを使用して HTTP メッセージを受信します。アクターが新しい Jetty サーバーを開始したということですか?

Javaのakkaドキュメントは言う

http://doc.akka.io/docs/akka/2.4/java/camel.html#Consumer_timeout

Camel エンドポイントとアクター間の双方向通信は、askパターンを使用してリクエスト メッセージをアクターに送信することによって開始され、アクターは応答の準備ができたときにエンドポイントに返信します。

その後

http://doc.akka.io/docs/akka/2.4/java/camel.html#Asynchronous_routing

コンシューマ エンドポイントは、 tellメソッドを使用して要求メッセージをコンシューマ アクターに送信し、アクターは getSender() で応答を返します。彼らが準備ができたら教えてください。

両方のステートメントのどちらが正しいですか? Camelコンポーネントに依存していますか？

tell メソッドが使用されている場合、エンドポイントはどのクライアントに応答するかをどのように認識しますか?

ありがとう。

Akka で Apache Camel を使用しており、一定の間隔でメッセージ キューのステータスを確認しようとしています。
キューがそのステータスを定期的にログに記録していることがわかりますが、プログラムでこのチェックを実行できるようにしたいと考えています。

Alpakka-FTPを使用していますが、一般的な akka-stream パターンを探しているのかもしれません。FTP コネクタは、ファイルを一覧表示したり、それらを取得したりできます。

理想的には、次のようなストリームを作成したいと思います。

しかし、上で書いた 2 つの関数でそのようなストリームを作成することはできません。Flowのようなものを使用してそこに到達できるはずだと感じています

ls上記の関数と関数のみが与えられた場合、これは可能fromPathですか?

編集：

1 つのアクターと を使用して解決することはできますがmapAsync、それでももっと簡単にする必要があると感じています。

Camel in actionという本の例に従いました。csv データ形式をマーシャリングおよびアンマーシャリングする方法。ただし、(カンマ区切りの区切り記号) と分割されたボディを使用して csv ファイルをアンマーシャリングしたいと考えています。次に、コンテンツ ベースを使用.choiceして、必要なタスクに従ってメッセージを配信します。実際、最初の単純な例はうまくいきませんでした。camel 2.15.6 (camel-core、camel-context、camel-csv、commons-csv) と Java 7 を使用しました。

スタックトレースの下を見つけてください。