akka-stream

0熱

1答えて

私はexampleを見つけました。ここでakka-httpはSource.singleでリクエストを行うために使用されています。今、私はこのようなX秒ごとに実行されているポーリング要求を実装するためにSource.tickを使用したい：しかし import scala.concurrent.duration._ val request: _root_.akka.http.scaladsl

0熱

1答えて

ジェネリックストリームと抽象データ型のここ

は、私が trait RequestBuilder { type Out def complete(p: Promise[Out]): Unit } def makeRequest(in: RequestBuilder): Source[(RequestBuilder, Promise[in.Out]), Future[in.Out]] = { val p =

0熱

1答えて

Slick 3.0のクエリ結果をAkka Streams GraphStageに変換する

somoneがslick3.0を使用してmysqlにクエリを行い、クエリの結果がAkkaStream GraphStageに変換される例はありますか？自分でカスタムのGraphStageを書いてみたい（絶対に必要な場合を除き）。私は

0熱

1答えて

HTTPエンドポイント

私の現在のコードにすべてのデータを送信しアッカ・ストリームシンクを作成することはあり署名： def putObject(key: String, contentType: ContentType, data: Source[ByteString,_]): Future[HttpReponse] （アッカ-HTTPクライアントに単に代表者）私が署名をしたいと思います私はメモにすべてのバイトをバ

0熱

1答えて

Akka and Throttling

私はAkkaを初めて利用しており、メッセージを抑制するために使いたいと思っています。私は、バージョン2.4.2のために、次の例を見ていたアッカのJavaライブラリを使用したいが、残念ながらそれは今古くなっていると、最新バージョン（2.5.3）については http://doc.akka.io/docs/akka/2.4.2/contrib/throttle.html サポートされていません -

1熱

1答えて

Akkaをapache spark streaming＆Kafkaで使用しますか？

以下は、作業しようとしている高レベルの使用例です。私たちはKafkaトピックに公開されているストリームデータを持っており、モジュールはストリームとして学生IDを読み込み、各学生の複数のソースから関連データを取得し、各学生の計算を実行し、生徒をカフカの話題にする。ここで、1つの大きなSparkの仕事を書くこと、またはAkkaを使って各ソースに別々のサービスを提供し、俳優が学生IDの束を並行して作

1熱

1答えて

Akka-Httpのリクエスト本文を読み込み、各行を俳優のメッセージキューに送ります。

私の使用例に合った例を探していますが、これまで見つかっていません。アクタの着信メッセージキューに各行を送信する、巨大なプレーンテキストリクエストボディを処理する必要のあるAkka WebServiceを作成しています。ここにコードを書いてもらったり、サンプルページに私を向けることができますか？私が実際に開始する場所から見当がつかない：私には大きな問題は、一般的にストリームを扱っている（私の場

1熱

1答えて

alpakka、JMSおよびcorrelationId in jms.Message in

私はクライアントとサーバーの間でメッセージの送受信にalpakka（Scala）とJMSコネクタを使用しました。すべての作業は完璧ですが、わかりません - どのようにjms.MessageでcorrelationIdを設定できるか何か考えてください。ありがとうございました。

0熱

1答えて

代替（の削減）

私は愚かな質問を持っていますが、原因を知っていることができませんでした： import akka.{Done, NotUsed} import akka.actor.Status.Success import akka.actor.{ActorRef, ActorSystem} import akka.stream.scaladsl.{Flow, RunnableGraph, Sink, S

0熱

1答えて

列ファミリIDの不一致（見つかった52ac10b0-6e1b-11e7-82d3-c39cc53c1347;予想42e51050-6e1b-11e7-82d3-c39cc53c1347）

LagomオンラインオークションJavaを実行しているときにエラーが発生しました。 sbtを実行してください。runAll ERROR [Native-Transport-Requests-13] 2017-07-21 16:52:45,704 ErrorMessage.java:384 - Unexpected exception during request java.lang.Runtim