From dc61bb4648d569ae43fcd05886ad1ab84831529e Mon Sep 17 00:00:00 2001
From: tjq <tengjiqi@gmail.com>
Date: Sun, 22 Jan 2023 17:11:56 +0800
Subject: [PATCH] fix: JavaUtils cache failed in windows env

---
 .../src/main/java/tech/powerjob/common/utils/JavaUtils.java    | 3 ++-
 .../java/tech/powerjob/remote/akka/AkkaMappingService.java     | 3 +++
 .../src/main/resources/application.properties                  | 2 +-
 3 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/powerjob-common/src/main/java/tech/powerjob/common/utils/JavaUtils.java b/powerjob-common/src/main/java/tech/powerjob/common/utils/JavaUtils.java
index f4ffd088..efff1973 100644
--- a/powerjob-common/src/main/java/tech/powerjob/common/utils/JavaUtils.java
+++ b/powerjob-common/src/main/java/tech/powerjob/common/utils/JavaUtils.java
@@ -53,8 +53,9 @@ public class JavaUtils {
         }
         catch (Throwable t) {
             log.warn("[JavaUtils] determinePackageVersion for clz[{}] failed, msg: {}", clz.getSimpleName(), t.toString());
+            // windows 下无权限访问会一直报错一直重试，需要在此兼容
+            return "UNKNOWN";
         }
-        return null;
     }
     private static String getImplementationVersion(JarFile jarFile) throws IOException {
         return jarFile.getManifest().getMainAttributes().getValue(Attributes.Name.IMPLEMENTATION_VERSION);
diff --git a/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaMappingService.java b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaMappingService.java
index ac4392d6..afe1f3af 100644
--- a/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaMappingService.java
+++ b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaMappingService.java
@@ -24,6 +24,9 @@ public class AkkaMappingService {
     static {
         addMappingRule(RemoteConstant.S4W_PATH, "server_actor", "w-r-c-d");
         addMappingRule(RemoteConstant.S4S_PATH, "friend_actor", "friend-request-actor-dispatcher");
+
+        addMappingRule(RemoteConstant.WTT_PATH, "task_tracker", "task-tracker-dispatcher");
+        addMappingRule(RemoteConstant.WPT_PATH, "processor_tracker", "processor-tracker-dispatcher");
     }
 
     private static final String DEFAULT_DISPATCH_NAME = "common-dispatcher";
diff --git a/powerjob-worker-samples/src/main/resources/application.properties b/powerjob-worker-samples/src/main/resources/application.properties
index c7249888..f2f6e1b0 100644
--- a/powerjob-worker-samples/src/main/resources/application.properties
+++ b/powerjob-worker-samples/src/main/resources/application.properties
@@ -10,7 +10,7 @@ powerjob.worker.app-name=powerjob-worker-samples
 # Address of PowerJob-server node(s). Ip:port or domain. Multiple addresses should be separated with comma.
 powerjob.worker.server-address=127.0.0.1:7700,127.0.0.1:7701
 # transport protocol between server and worker
-powerjob.worker.protocol=http
+powerjob.worker.protocol=akka
 # Store strategy of H2 database. disk or memory. Default value is disk.
 powerjob.worker.store-strategy=disk
 # Max length of result. Results that are longer than the value will be truncated.