package tech.powerjob.remote.akka; import tech.powerjob.remote.framework.base.ServerType; /** * AkkaConstant * * @author tjq * @since 2022/12/31 */ public class AkkaConstant { public static final String AKKA_CONFIG = "powerjob.akka.conf"; public static final String WORKER_ACTOR_SYSTEM_NAME = "oms"; public static final String SERVER_ACTOR_SYSTEM_NAME = "oms-server"; /** * 获取 actorSystem 名称 * @param serverType 当前服务器类型,powerjob-server 为 server,powerjob-worker 为 worker * @return actorSystemName */ public static String fetchActorSystemName(ServerType serverType) { return serverType == ServerType.SERVER ? SERVER_ACTOR_SYSTEM_NAME : WORKER_ACTOR_SYSTEM_NAME; } }