v0

Bughue · Dec 4, 2024 · cfde859 · cfde859
1 parent 3e3f5da
commit cfde859
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/core/src/main/java/org/apache/seata/core/protocol/Version.java b/core/src/main/java/org/apache/seata/core/protocol/Version.java
@@ -94,8 +94,8 @@ public static boolean isAboveOrEqualVersion230(String version) {
         return isAboveOrEqualVersion(version, VERSION_2_3_0);
     }
 
-    public static boolean isAboveOrEqualVersion071(String version) {
-        return isAboveOrEqualVersion(version, VERSION_0_7_1);
+    public static boolean isV0(String version) {
+        return !isAboveOrEqualVersion(version, VERSION_0_7_1);
     }
 
     public static boolean isAboveOrEqualVersion(String clientVersion, String divideVersion) {

diff --git a/core/src/main/java/org/apache/seata/core/rpc/MsgVersionHelper.java b/core/src/main/java/org/apache/seata/core/rpc/MsgVersionHelper.java
@@ -42,8 +42,8 @@ public static boolean versionNotSupport(Channel channel, RpcMessage rpcMessage)
         if (StringUtils.isBlank(version) || msg == null) {
             return false;
         }
-        boolean aboveV0 = Version.isAboveOrEqualVersion071(version);
-        if (aboveV0 || !(msg instanceof MessageTypeAware)) {
+        boolean aboveV0 = Version.isV0(version);
+        if (!aboveV0 || !(msg instanceof MessageTypeAware)) {
             return false;
         }
         short typeCode = ((MessageTypeAware) msg).getTypeCode();