Bug fix

ZiluTian · Sep 6, 2024 · b517d56 · b517d56
1 parent 292dc58
commit b517d56
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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 => {