akka.net-persistence

0熱

1答えて

akka.net永続性を使用して、いくつかのメッセージタイプをSQL Serverデータベースに格納しました。そしてそのビジネスシナリオでは、それは機能します。他のケースでは、私はちょうどC＃.netを使用してメッセージを非直列化し、akka.netなしのメッセージプロパティを見たいと思っていました。どうすればそれが可能でしょうか？

0熱

2答えて

Akka.netとAkka.PersistenceでCQRSのEventBusを適用する方法

私はAkka.netでCQRSとEvent Sourcingを適用する方法に興味があります。私はすでにAkka.PersistenceにES部分を配達していることに気づいた。私が理解している限り、コマンドハンドラとAggergateRootは、単一クラスのReceivePersistentActorで表すことができます。私は public abstract class AggregateRoot

0熱

1答えて

akka.net永続アクタをテストするには

私は[Akka.Net 1.3.1]をReceiveActorsとReceivePersistentActorsの組み合わせで使用しています。これで私のアクターシステムのテストを書きたいと思います。 MyPersistentActorはReceivePersistentActorから継承し、MyActorはReceiveActorから継承します。バージョン1.3.1を使用してAkka.TestK

1熱

1答えて

イベントを再生するときの永続性の失敗... System.NotSupportedException：汎用IDictionaryはまだサポートされていません

助けてもらえますか？ 1〜2回保存するとうまく動作します。 3つ以上、私はこれを取得しています： [INFO][11/28/2017 2:57:27 PM][Thread 0005][[akka://ECHO3DEV/user/api-master/PortfolioCoordinator/TK#425630680]] Portfolio Actor: TK completely recovere

0熱

1答えて

Akka.NETの永続性は、IActorRefを含むメッセージの再生をどのように処理しますか？

私はAkka.NETの俳優にIActorRefを含むオブジェクトであるメッセージを送信し、そのメッセージを解決しない場合は、ジャーナルテーブルに書き込まれたJSONは次のようになります。私はこれを理解していた場合 {"$id":"1","$type":"LearningAkka.Program+BindReference, LearningAkka","Reference":{"$id":"2",

3熱

1答えて

Akka.Persistenceリカバリの順序は何ですか？

私はPetabridgeのブログでAkka.Persistence introを読んだ、と私は、コードのこの部分は少し混乱を見つける：あなたはおそらく回復に何をしたいのか Recover<string>(str => _msgs.Add(str)); // from the journal Recover<SnapshotOffer>(offer => { var messa

0熱

1答えて

アクター用のストアオブジェクト用のSHARED LISTを作成する方法は？

私は店舗を与える商品のピックアップの平均完了時間を計算したいと思います。ピッキングモジュールは、ピックアップがアクタAに完了した時点で、完了するまでの時間をメッセージに送信し、別のストアでピッキング操作を完了するたびに、ストアの完了と所要時間を示すメッセージを送信しますアクタは、これらのメッセージを共有リストに格納します。ある時点で、別の俳優Bが俳優Aから店舗Xでピックを完了するのに要する平均時間

6熱

1答えて

Akka .NET接続プールのタイムアウトに関する問題

Akka.NETを使用して新しいシステムを作成し、シャーディングと永続性を備えた基本的なクラスタセットアップを行います。シャーディングが正しく機能するように、公式のドキュメントとPetBridgeブログの記事を使用しました。ただし、シャードがSQL Server接続プールで許可されている最大接続数を超えているという問題が発生しました。 04：：そのため、我々は... 2017年4月20日14を次