chylex/Minecraft-Phantom-Panel
1
0
Fork 0
mirror of https://github.com/chylex/Minecraft-Phantom-Panel.git synced 2025-11-09 07:43:38 +01:00
Code Activity

Compare commits

base: chylex:02828a91c64007eb9f50d9f0f0f489d44b79266a
Branches Tags
chylex:main chylex:wip-forge chylex:wip-launchers chylex:experimental/agent-shutdown chylex:experimental/agent-name-generator
..
compare: chylex:873d0368959f5caffc9841893f9b9fb492819abd
Branches Tags
chylex:main chylex:wip-forge chylex:wip-launchers chylex:experimental/agent-shutdown chylex:experimental/agent-name-generator

2 Commits
02828a91c6 ... 873d036895

Author SHA1 Message Date
chylex
873d036895 Migrate event log to Akka.NET 2024-03-22 03:47:29 +01:00
chylex
b32a9dba6b Migrate RPC message handling to Akka.NET 2024-03-22 03:47:29 +01:00
1 changed files with 1 additions and 1 deletions
Expand all files Collapse all files

2
Agent/Phantom.Agent/Program.cs
View File

@@ -58,7 +58,7 @@ try {
var agentServices = new AgentServices(agentInfo, folders, new AgentServiceConfiguration(maxConcurrentBackupCompressionTasks), new ControllerConnection(rpcSocket.Connection)); var agentServices = new AgentServices(agentInfo, folders, new AgentServiceConfiguration(maxConcurrentBackupCompressionTasks), new ControllerConnection(rpcSocket.Connection));
await agentServices.Initialize(); await agentServices.Initialize();
using var actorSystem = ActorSystemFactory.Create("Agent"); using var actorSystem = ActorSystemFactory.Create("Web");
var rpcMessageHandlerInit = new ControllerMessageHandlerActor.Init(rpcSocket.Connection, agentServices, shutdownCancellationTokenSource); var rpcMessageHandlerInit = new ControllerMessageHandlerActor.Init(rpcSocket.Connection, agentServices, shutdownCancellationTokenSource);
var rpcMessageHandlerActor = actorSystem.ActorOf(ControllerMessageHandlerActor.Factory(rpcMessageHandlerInit), "ControllerMessageHandler"); var rpcMessageHandlerActor = actorSystem.ActorOf(ControllerMessageHandlerActor.Factory(rpcMessageHandlerInit), "ControllerMessageHandler");