feat: optimize akka remote impl

This commit is contained in:
tjq 2023-01-02 11:24:44 +08:00
parent f2b9ae222a
commit 432adeb00f
3 changed files with 2 additions and 4 deletions

View File

@ -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

View File

@ -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";

View File

@ -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();
}
}