From bfe4565cbda7371832135c3db3ac5c75e9520d63 Mon Sep 17 00:00:00 2001 From: opensnail <598092184@qq.com> Date: Wed, 11 Sep 2024 21:40:22 +0800 Subject: [PATCH] =?UTF-8?q?feat:(1.2.0-beta1.1):=20=E4=BF=AE=E5=A4=8DGRPC?= =?UTF-8?q?=E7=B1=BB=E5=9E=8B=E5=90=8D=E7=A7=B0=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../snailjob/client/common/rpc/client/SnailJobGrpcClient.java | 2 +- .../snailjob/client/common/rpc/server/SnailGrpcServer.java | 2 +- .../java/com/aizuda/snailjob/common/core/enums/RpcTypeEnum.java | 2 +- .../aizuda/snailjob/server/common/rpc/server/GrpcServer.java | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/rpc/client/SnailJobGrpcClient.java b/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/rpc/client/SnailJobGrpcClient.java index 666bf460..287dc859 100644 --- a/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/rpc/client/SnailJobGrpcClient.java +++ b/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/rpc/client/SnailJobGrpcClient.java @@ -32,7 +32,7 @@ public class SnailJobGrpcClient implements Lifecycle { @Override public void start() { - if (RpcTypeEnum.GPRC != snailJobProperties.getRpcType()) { + if (RpcTypeEnum.GRPC != snailJobProperties.getRpcType()) { return; } diff --git a/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/rpc/server/SnailGrpcServer.java b/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/rpc/server/SnailGrpcServer.java index b1aed440..5d934929 100644 --- a/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/rpc/server/SnailGrpcServer.java +++ b/snail-job-client/snail-job-client-common/src/main/java/com/aizuda/snailjob/client/common/rpc/server/SnailGrpcServer.java @@ -55,7 +55,7 @@ public class SnailGrpcServer implements Lifecycle { @Override public void start() { - if (started || RpcTypeEnum.GPRC != snailJobProperties.getRpcType()) { + if (started || RpcTypeEnum.GRPC != snailJobProperties.getRpcType()) { return; } diff --git a/snail-job-common/snail-job-common-core/src/main/java/com/aizuda/snailjob/common/core/enums/RpcTypeEnum.java b/snail-job-common/snail-job-common-core/src/main/java/com/aizuda/snailjob/common/core/enums/RpcTypeEnum.java index c3bf279d..2349abea 100644 --- a/snail-job-common/snail-job-common-core/src/main/java/com/aizuda/snailjob/common/core/enums/RpcTypeEnum.java +++ b/snail-job-common/snail-job-common-core/src/main/java/com/aizuda/snailjob/common/core/enums/RpcTypeEnum.java @@ -6,6 +6,6 @@ package com.aizuda.snailjob.common.core.enums; */ public enum RpcTypeEnum { - GPRC, + GRPC, NETTY } diff --git a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/GrpcServer.java b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/GrpcServer.java index 47734456..b9bfdb93 100644 --- a/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/GrpcServer.java +++ b/snail-job-server/snail-job-server-common/src/main/java/com/aizuda/snailjob/server/common/rpc/server/GrpcServer.java @@ -58,7 +58,7 @@ public class GrpcServer implements Lifecycle { return; } - if (RpcTypeEnum.GPRC != systemProperties.getRpcType()) { + if (RpcTypeEnum.GRPC != systemProperties.getRpcType()) { return; }