diff --git a/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaCSInitializer.java b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaCSInitializer.java
index 0565c22e..b93e9206 100644
--- a/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaCSInitializer.java
+++ b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaCSInitializer.java
@@ -32,7 +32,7 @@ public class AkkaCSInitializer implements CSInitializer {
 
     @Override
     public String type() {
-        return AkkaConstant.PROTOCOL;
+        return tech.powerjob.common.enums.Protocol.AKKA.name();
     }
 
     @Override
diff --git a/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaConstant.java b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaConstant.java
index b40d4b8c..efd191c4 100644
--- a/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaConstant.java
+++ b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaConstant.java
@@ -10,8 +10,6 @@ import tech.powerjob.remote.framework.base.ServerType;
  */
 public class AkkaConstant {
 
-    public static final String PROTOCOL = "AKKA";
-
     public static final String AKKA_CONFIG = "powerjob.akka.conf";
 
     public static final String WORKER_ACTOR_SYSTEM_NAME = "oms";
diff --git a/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaProtocol.java b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaProtocol.java
index e2e04c0b..ca1a7a66 100644
--- a/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaProtocol.java
+++ b/powerjob-remote/powerjob-remote-impl-akka/src/main/java/tech/powerjob/remote/akka/AkkaProtocol.java
@@ -11,6 +11,6 @@ import tech.powerjob.remote.framework.transporter.Protocol;
 public class AkkaProtocol implements Protocol {
     @Override
     public String name() {
-        return AkkaConstant.PROTOCOL;
+        return tech.powerjob.common.enums.Protocol.AKKA.name();
     }
 }