akka-stream

3熱

1答えて

私はAkka Distributed Pub/Subを使用しており、出版社とサブスクライバは1つです。私の出版社は加入者よりもずっと高速です。ある時点後に出版社を遅らせる方法はありますか？出版社コード： public class Publisher extends AbstractActor { private ActorRef mediator; static publi

0熱

1答えて

クライアントアプリケーション用のakka-streamsとakka-httpを使用した認証の処理方法

認証済みWebサービス（認証トークンを返す）に接続する必要があるAkka StreamsとAkka Httpを使用してアプリケーションを作成しています定期的にサービスを照会し、クエリに応じて他のアクションを実行する可能性があります（ファイルのダウンロードなど）。認証トークンは一定の時間が経過するとタイムアウトするため、リフレッシュする必要があります。認証トークンはどのように処理すればよいですか？

2熱

2答えて

レスポンスカフカで失敗したメッセージを再実行する方法0.8.2.2

処理に失敗した回数x回のメッセージを再発行します。私は手動コミットコードを参照してください：しかし、processMessage（）メソッドで例外を処理する方法はありますか？私は例外を処理し、カフカにメッセージを3回実行するように依頼したいと思います。それでも3回失敗したら、それを捨ててください。

2熱

1答えて

Akka http-clientはサーバーからのすべてのデータストリームを消費することはできません

このストリームを消費するためのシンプルなakkaストリーム休止エンドポイントとクライアントを作成しようとしています。しかし、私はサーバーとクライアントを実行しようとすると、クライアントはストリームの一部だけを消費することができます。私は実行中に例外を見ることができません。ここでは私のサーバーとクライアントです： import akka.NotUsed import akka.actor.Act

0熱

2答えて

Akka-http：localhostのwebsocketに接続

私はlocalhostのwebsocketを通していくつかのサーバに接続しようとしています。 ws = new WebSocket('ws://localhost:8137'); でJSでやろうとすると成功します。しかし、akka-httpとakka-streamsを使用すると、「接続に失敗しました」というエラーが表示されます。 object Transmitter { implic

1熱

1答えて

Akkaはalpakka jmsのKillSwitchをストリームします

私はalpakkaを使用して複数のjmsSource（異なるキュー用）を開始するシナリオを持っています。私はまた、キューをいつでも切り離す必要があります。そこで、以下のようにjms akkaストリームにKillSwitchを追加しました： - trait MessageListener { lazy val jmsPipeline = jmsSource .map { x =

1熱

2答えて

複数のシンクが

私はこの二つのシンクなどのストリームを持っているが、一方のみが一度に使用されます。 Source.fromElements(1, 2, 3) .via(flow) .runWith(sink1) または Source.fromElements(1, 2, 3) .via(flow) .runWith(sink2) それは設定可能です我々が使用沈みます両方のシンクを並行して使用すると

1熱

1答えて

Slickストリーミングデータの変換とAkka Httpを使用したチャンクレスポンスの送信

目的は、データベースからデータをストリーミングし、このデータチャンクで何らかの計算を実行することです（この計算は、あるケースクラスの未来を返します）ユーザに提供する。現在、私はデータをストリーミングし、計算を実行せずに応答を送信できます。しかし、私はこの計算を実行できず、結果をストリーミングすることができません。これは私が実装したルートです。 def streamingDB1 = path("