akka-persistence

0熱

1答えて

私は現在、同じ俳優に到達する複数の方法がある現在構築中のシステムにかなりの場所があります。たとえば、あなたが永続的な車の俳優を持っている場合、あなたはVINまたは登録プレートを使用することができます。アクターを再作成するときにアクター名/パーシスタンスIDとして使用する単一の「真の名前」が必要なので、これらの「ルックアップ/参照」自体がアクターのIDを維持したまま、参照。これは正しい方法ですか

2熱

1答えて

コラム家族のIDのミスマッチ（cebcc380-72d4-11e7-9a6b-bd620b945799た;期待c05d6970-72d4-11e7-9a6b-bd620b945799）

私は、このエラーにカラム家族IDの不一致を解決するにはどうすればよい（見つけcebcc380-72d4-11e7- 9a6b-bd620b945799; c05d6970-72d4-11e7-9a6b-bd620b945799予想） Caused by: java.util.concurrent.ExecutionException: org.apache.cassandra.exception

0熱

2答えて

イベントソーシングと組み合わせてサーバーレスですか？

私はしばらくの間、完全なサーバーレスアーキテクチャを使用してモバイルアプリを実装したいと思っていましたが、最後に詳細を調べ始めました。これまでのところ、AWSはそのような設定（API Gateway、Cognito、Lambda、DynamoDB、SQSなど）に必要なサービスのほとんどを提供していますが、問題;イベントソーシング。最近（歴史的）データはますます価値が高まっているため、私の謙虚な意

0熱

1答えて

Akka ShardRegion.StartEntityメッセージはエンティティアクタに伝播されますか？

私はScala 2.12.2でAkka 2.5.2を使用しています。 sharding docには、クラッシュ/リバランスされた断片をエンティティを回復するために、がShardRegion.StartEntityメッセージを処理する必要があることが記載されています。エンティティ自体が内部状態を回復する必要がある場合は、PersistenceActorを実装する必要があります。これを機能させるには

2熱

1答えて

Akka-Persistence：スナップショットを取得する方法

akka-persistenceで古いスナップショットをクエリするにはどうすればよいですか？ SnapshotStoreには私的に利用可能であるが、他の方法では呼び出せないメッセージがあることがわかります。LoadSnapshot はsnapshotterのインターフェイスがある - >loadSnapshot が、これは役者へのコールバックを与え、私は必要なものではありません。 /**

1熱

1答えて

永続アクタを使用したAkka Shardingの背圧

Akkaストリーム背圧モデルまたは永続アクタを使用したakkaシャーディングを使用するためのものはありますか？私には問題があるため、永続的なアクターを持つAkkShardingクラスタがあります。（ジャーナルプラグインとしてcassandraを使用）。多くの場合、複数のアクターを同時に作成する必要があります。（たとえば、すべてのユーザにブロードキャストメッセージを送信する場合）と数千の永

1熱

1答えて

基本的なアカウンティング俳優とその状態

これはakkaに関する非常に基本的な質問です。私はakka上で完全に緑色なので、任意のアドバイスをいただきありがとうございます。何百万人ものユーザーではなく、何千ものユーザーがいるアプリケーションがあるとします。ドメインモデルは、各ユーザーがある国のある地域、つまり複数の地域を持つ国、複数のユーザーを持つ地域の階層です。私はakkaに全く同じ階層を作成しようと考えています。 CountryA

0熱

1答えて

AbstractPersistenceActorのcreateReceiveメソッドとcreateReceiveRecoverメソッドは何ですか？

2.3.2 APIに基づいて詳細を記述したTypeSafeダウンロードAkkaJava.pdfファイルを調べていました。第4.4章永続性（Java with Lambda Support）では、メッセージを処理するためにオーバーライドする必要のあるメソッドであるreceiveRecover()とreceiveCommand()がリストされています。私は自分のIDEを2.5.2バージョンのAKKA

1熱

1答えて

Akka persistence cassandra NoSuchMethodError on sturtup

私は、利用可能なオプションを比較するために、異なるakka-persistenceプラグインで遊んでいます。今度は、メモリ内の& leveldbプラグインで正常に実行できますが、cassandraプラグインでランタイム例外が発生します。 akka { persistence { # predefined inmemory plugin # journal.plugi

1熱

1答えて

deliveryId owerflow for AtLeastOnceDelivery保証akka永続性

私はいくつかのAtLeastOnceDeliveryデコレータを実装して、さまざまなアクターに対して信頼できるメッセージングを実現しようとしています。したがって、このようなデコレータは、かなり集中的なメッセージングを処理しようとし、アプリケーションとlyfecycleを共有します。 AtLeastOnceDelivery documentationによればdeliveryIdは隙間なく、厳密に単調