From b517d563b722b8092b90ec6b0892017fa94d2ae9 Mon Sep 17 00:00:00 2001 From: Tian Zilu Date: Fri, 6 Sep 2024 11:28:49 +0200 Subject: [PATCH] Bug fix --- Akka/src/main/scala/core/WorkerImpl.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/Akka/src/main/scala/core/WorkerImpl.scala b/Akka/src/main/scala/core/WorkerImpl.scala index 9b045ec1..5b838154 100644 --- a/Akka/src/main/scala/core/WorkerImpl.scala +++ b/Akka/src/main/scala/core/WorkerImpl.scala @@ -62,8 +62,8 @@ class Worker { Prepare() case LogControllerSpec.LoggerAggregateServiceKey.Listing(logger) => - ctx.log.debug(f"Log controller registered!") if (logger.size == 1) { + ctx.log.debug(f"Log controller registered!") loggerRef = logger.head } Prepare() @@ -88,7 +88,7 @@ class Worker { Behaviors.receive[WorkerEvent] { (ctx, message) => message match { case Prepare() => - worker(builder) + Behaviors.same case ReceiveAgentMap(wid, nameIds, reply) => peerWorkers.computeIfAbsent(wid, x => {