akka.net

    1熱度

    1回答

    我想添加和刪除角色到池(組?),應該通過使用一致的哈希映射(消息具有與實體路徑一致的ID)接收消息的消息。 但創建池後,只有IActorRef返回,我不知道如何「告訴」有關新演員添加。 我已閱讀了關於路由的幾個教程和提示,例如:https://github.com/petabridge/akka-bootcamp/tree/master/src/Unit-3/lesson2 但這些不適合。 也許我

    0熱度

    1回答

    我需要測試我的演員是否對Terminated消息作出正確反應,並且我使用TestProbe來嘲笑它的孩子。但由於某種原因,我不能停止TestProbe演員。下面是測試: [Test] public void TestProbeStopTest() { var probe = CreateTestProbe("Test"); Watch(probe);

    1熱度

    1回答

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

    2熱度

    1回答

    我們正在akka.net上處理json文件的POC。我正在努力處理批量處理JArray的最佳方法。我在執行阿卡協調演員收到以下消息: //coordinator actor receive public class ValidatedInput { public JArray Data { get; set; } } 我協調演員可以處理完整JArray在一個單一的去像下面,但我很努力,

    2熱度

    1回答

    問題: 我努力理解爲什麼基於下面的語句是在我的發電機演員我的記者的演員是沒有收到消息: reporter <! Message input 我的記者的演員如下: let reporterActor (mailbox:Actor<_>) = let rec loop() = actor { let! msg = mailbox.Receive() match m

    1熱度

    2回答

    我在akka.net中使用遠程演員長期保持windows服務。我使用ActorSelection爲遠程actor創建一個IActorRef,並在服務中保持IActorRef長時間處於活動狀態。 IActorRef指向在另一個Windows服務中運行的角色系統。 我明白,遠程actor的重啓不會使遠程actor參數失效。但是,可以想象,遠程Windows服務可能會在某個時間點重新啓動,並且調用Win

    0熱度

    1回答

    我想知道,如何實現與Akka.Net的繼承。我希望基礎演員處理基本消息和處理子消息的子演員。 例如,我有以下層次: public class BaseMessage { public string Data { get; set; } } public class ChildMessage : BaseMessage { public string ChildData

    1熱度

    1回答

    作爲改變我們的應用從巨型巨石到麥克風的一部分我們正在開發通知微服務,可供所有其他模塊用於發送電子郵件,SMS ,推送通知等。 此通知服務的一個客戶端是我們計劃開發的Windows服務,這會觸發用戶註冊,密碼重置等各種事件的電子郵件通知。 Windows服務將有一個2部分 一個基於REST的API,可以由用戶註冊等模塊調用觸發通知。當ReST API被調用時,該服務將加載適當的模板,填寫必要的值並調

    0熱度

    1回答

    每次我在Akka.NET中創建一個新類型的對象時。這種類型的全部期刊被加載在構造 我的測試: [Test, Category("Integration")] public async Task Should_Persist_Actor() { var model = Mocks.Fake.Contact(); await Actors.Cont

    0熱度

    1回答

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