akka.net-persistence

0熱度

1回答

我正在編寫Akka.Persistence for Service Fabric的實現，並且我似乎無法獲取快照的工作方式。當它嘗試恢復狀態時，它會獲取最新的快照，但它不會重播自最新快照以來的事件。它對我不清楚如果我沒有正確連接組件，或者如果我的持久性庫的實現不正確。我的演員是一個簡單的計數器，我的狀態只是當前的計數。我希望恢復應該先被調用，然後在最後一個快照和最高序列號之間爲每個日記條目調用R

0熱度

1回答

Akka.NET持久性如何處理重放包含IActorRef的消息？

如果我發送一個Akka.NET演員的消息即含有IActorRef的對象，然後堅持這一信息，寫入日誌表中的JSON看起來是這樣的： {"$id":"1","$type":"LearningAkka.Program+BindReference, LearningAkka","Reference":{"$id":"2","$type":"Akka.Actor.ActorRefBase+Surrogate

0熱度

1回答

更新到1.3.1.0後Akka.Persistence問題

一切正常工作....然後我決定更新到AKKA.NET 1.3.1.0 ... 有許多問題，並解決它們，但是我似乎無法找到最後一個解決方案（我希望）。錯誤消息： ---> System.Reflection.TargetInvocationException：異常被調用的目標引發。 ---> System.MissingMethodException：未找到方法：'虛假 Akka.Persisten

0熱度

1回答

如何爲演員的商店對象創建共享列表？

我想計算商店中商品的平均完成時間。揀配模塊將發送帶有時間完成的消息並存儲完成時向Actor A的名稱。如希望每次完成在不同商店中的挑選操作，它會發送一條消息，其中需要多長時間才能完成商店名稱演員A.演員將這些消息存儲在共享列表中。在某個時候，另一個演員B會向演員A問什麼是在商店X完成選擇所需的平均時間。我的問題是如何將消息存儲在共享列表中，這將是任何類型actor A的演員？

1熱度

1回答

Akka.net集羣分片：無法註冊協調器

我試圖通過創建simple project來設置akka.net集羣分片。項目佈局：演員 - 類庫，它定義了一個演員和消息。由其他項目引用入站 - 啓動ShardedRegion並且是參與集羣分片的唯一節點。而且應該是主持協調員的人。 MessageProducer - 將只承載shardedregion代理將消息發送到ProcessorActor。燈塔 - 種節點 Uploaded im

6熱度

1回答

Akka .NET連接池超時問題

我們正在創建一個使用Akka.NET的新系統，並具有分片和持久性的基本集羣設置。我們已經使用官方文檔以及一些Petabridge博客帖子來使分片正常工作。但是，我們遇到了分片超過SQL Server連接池允許的最大連接數的問題。因此，我們得到以下信息... 2017年4月20日14：04：31.433 +01：00【警告】「超時過期的超時時間已過獲取連接之前，發生這種情況的原因可能是因爲所有

0熱度

1回答

使用C＃De-Serialize akka.net持久性消息

我使用akka.net持久性來在sql server數據庫中存儲一些消息類型。在這種業務場景下它可以工作。在其他情況下，我只是想使用C＃.net反序列化消息，並在不使用akka.net的情況下查看消息屬性。怎麼可能？

2熱度

1回答

Akka.net持久性參與者恢復失敗，消息更改爲新屬性

使用持久性參與者將消息持久存入SQL Server數據庫。初始消息格式如下。系統幾次運行這種格式，並且這些消息中的許多消息被保存。目前我改變了消息格式以包含如下的幾個屬性。有人能給我一個想法如何解決這個問題嗎？目前我面臨的問題是恢復最初的持久消息與新的更改失敗，並給出如下錯誤。「重播persistenceId [tz-persistent-factory]的事件時發生持久性失敗。最後已知序列號

1熱度

1回答

Akka.Net和在內存中的存在

我試圖讓我的頭部持久化，我還沒有能夠恢復演員。我的意圖是通過它的persistenceId獲得一個Actor（與我們在DDD中使用GetById獲得一個實體的方式相同）。我可以得到對List的引用並將它添加到列表管理器中的一個變量中，但我所尋找的是一旦演員死掉了如何獲取Actor的當前狀態（Revovery By Events）以便修改可以做完了。讓我知道如果我的問題不明確這是我迄今所做的

0熱度

1回答

如何測試akka.net執行者演員

我使用[Akka.Net 1.3.1] ReceiveActors和ReceivePersistentActors的混合，現在我想爲我的演員系統編寫測試。 MyPersistentActor繼承自ReceivePersistentActor，MyActor繼承ReceiveActor。我還使用版本1.3.1安裝了Akka.TestKit。但似乎只有ReceiveActors可以通過Akka.T