akka-camel

2熱

1答えて

私はAlpakka-FTPを使用していますが、多分私は一般的なakka-streamパターンを探しています。 FTPコネクタは、ファイルを一覧表示したり、それらを取得することができます。 def ls(host: String): Source[FtpFile, NotUsed] def fromPath(host: String, path: Path): Source[ByteString,

1熱

1答えて

Camel JettyコンポーネントはAkkaでどのように動作しますか？

次の例（Akka Camel docから取得）では、Jetty HTTPコンポーネントを使用してHTTPメッセージが受信されます。俳優が新しい桟橋サーバーを始めることを意味しますか？ import akka.camel.{ CamelMessage, Consumer } class MyEndpoint extends Consumer { def endpointUri = "j

0熱

1答えて

Akka Scala Camel。例外処理

私はakka camel-ftpです。私はコード内のすべての例外を処理したいと思います（例えば、認証例外、またはftp上のファイルを読むことはできません）。 stacktraceがログにのみ表示され、処理できません。 scalaz-camelを使用する方が良いかもしれません。さらに私は、すべてのファイルが処理され、それまでは俳優、アイドル、次のあなたはスーパーバイザーの内側にあなたのアクターを実

4熱

1答えて

エンドポイントが見つかりすることができませ：テスト、確認していないしてください、あなたのクラスパスが必要なキャメルコンポーネントジャー

が含まれている私はakka-camelを使用してメッセージを送受信しようとすると、下記のように生産者と消費者のためのサンプル例を作成しています：プロデューサー： import akka.actor.{Actor, ActorSystem, Props} import akka.camel.Producer class CamelJmsProducer extends Actor with

0熱

1答えて

キャメルアッカとアクターからの返信

親愛なるアクカ/キャメルマスターズ！私はルート以下います（netty4：TCP） - >（アッカ：俳優）を私はアッカ・ラクダのモジュールを使用しています：アッカを：俳優はタイプUntypedConsumerActorでありますIは、TCPソケットにバイトを送信すると、私はどのTEL例外を受け取る俳優 netty4:tcp://localhost:8000?textline=true ：

0熱

1答えて

Akka CamelでTwitterにアクセスしてJSONを返す

URL "https://stream.twitter.com/1.1/statuses/filter.json"を使用してHTTP POSTメソッドを使用していましたが、体内で私はキー/値を投稿していました。たとえば、 "track = london" 。これはうまくいきました。今、私はAKKA-CAMELに切り替えようとしています。私は彼らのTwitterユーザーを利用しています。私はTwi

0熱

2答えて

コンシューマ/プロデューサAWS SQSシンクロンコンシューマを使用するakaスカラ

私のアプリケーションにはプロデューサとコンシューマがあります。私のプロデューサーは不規則にメッセージを出します。いつか私のキューは空になるでしょうが、いつか私はいくつかのメッセージを持っています。私は消費者に待ち行列を聞かせてもらいたいと思います。メッセージが入っているときは、取り出してこのメッセージを処理してください。このプロセスには数時間かかることがあり、現在のメッセージの処理が完了して

1熱

1答えて

Apache Camelでのメッセージキュー接続の状態を確認してください

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