akka-persistence

3熱

1答えて

スナップショットストア内の古いスナップショットを簡単にクリーニングする：成功したスナップショットごとに、アクターはシーケンス番号を示すメタデータを含むsaveSnapshotSuccessを受け取ります。スナップショットSnapshotSelectionCriteriaを入力し、deleteSnapshotsに入力してください。しかし、持続メッセージの場合はsaveSnapshotSuccess

0熱

1答えて

すべての永続アクタはインメモリにありますか？

私はAkkaの永続Order Actor（Cassandraに残っていると言います）の注文を受けています。私のシステムには多くの注文があります。いつでも、すべてのオーダー・アクターはメモリー内にありますか？あるいは、必要に応じて、いくつかの注文俳優のうちの何人かがキャサンドラから回収されるだろうか？内部的にどのように機能しますか？ *ほとんど必要とされないエンティティ

1熱

1答えて

Google Protobuf、.protoファイルクエリ

次のCRMDataケースクラスのために.protoファイルを作成する必要があります。私は、次のデータ型との混同を持っていますが、ネストされたマップやユーザー定義のクラス（ShipToGroup） case class CRMData( var customerShipToGroups : Map[String, Map[UUID, ShipToGroup]], var sh

1熱

1答えて

クラッシュ後に動的に作成された永続化AKKAアクターを再作成する方法

プロジェクト用にAkkaを評価していますが、Akka-Persistenceでハイアベイラビリティを達成できるかどうかは、格納。私はアクターの状態を保存するというコンセプトを理解しましたが、失敗した（クラッシュした）サービスを回復するためにアクター（アクターの状態ではありません）を再作成する方法を見つけるのに苦労しています。バックアップホスト上で実行します。私の設計では、多くの動的に作成された

0熱

1答えて

アクタシステム全体の状態をAkka.NETに保存することはできますか？

私はAkka.NETで読んできたことをよく読んできており、非常に基本的なオンラインマルチプレイヤーゲームに適していると感じています。私は特にAkka.NET内のPersistenceモジュールに興味がありました。私ができることが大好きなのは、任意の時点で私のActorシステム全体のスナップショットを撮り、選択した時点でそのスナップショットを復元することです（本質的にゲーム状態のSave/Load

0熱

2答えて

akka永続アクターのテストイベントが生成されました

CQRSコマンドの定義によって、検証する必要がありますか、検証する必要があります（検証が合格しない場合）。コマンドの検証の一環として、状態遷移が本当に必要かどうかを確認します。したがって、単純なダミーの例を取ってみましょう。アクターは状態Aにあります。コマンドはアクターに送られて状態Bに遷移します。コマンドは有効になり、終了イベントではStateBUpdatedが生成されます。コマンドが検証さ

0熱

1答えて

Akka Persistence：ReadJournal.runFold never returns

私はAkka、より具体的にはAkka Persistenceを初めて実験しています。私は最終的にイベントソーシングアプリケーションでのAkkaの使用を複製する小さなおもちゃプログラムを実装しようとしています。私はReadJournalを使って私のイベントストリームを自分のドメインに投影しようとするまで、成功しました。 def main(args: Array[String]): Unit = {

0熱

1答えて

Akka.NET - AtLeastOnceDeliveryReceiveActorとPublish/Subscribeパターンを混在させることは可能ですか？

私はそれが原因というAtLeastOnceDeliveryReceiveActor実際に作業することはできませんAtLeastOnceDeliveryReceiveActor加入者がです（http://getakka.net/articles/clustering/distributed-publish-subscribe.html）パブリッシュ/サブスクライブ・パターンを実装することが可能ですか

0熱

1答えて

akkaシャードされたアクターの状態を外部化または発火させる方法を教えてください。

私はAkkaクラスタリングと概念実証に取り組んでいて非常に新しいです。私の場合、私はクラスター上で実行されている俳優を持っており、俳優はMap [String、Any]のような状態を持っています。そのため、任意の要求に対して、アクターは受信メッセージに基づいてそれを受け取り、新しいエンティティアクターとデータマップを作成します。ここで問題となっているのは、マップが現在メモリに入っていることです。赤