undolog

Bughue · Nov 1, 2024 · ff42508 · ff42508
1 parent 2c40745
commit ff42508
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 18 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,10 +94,6 @@ 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 isAboveOrEqualVersion(String clientVersion, String divideVersion) {
         boolean isAboveOrEqualVersion = false;
         try {

diff --git a/core/src/main/java/org/apache/seata/core/rpc/netty/AbstractNettyRemotingServer.java b/core/src/main/java/org/apache/seata/core/rpc/netty/AbstractNettyRemotingServer.java
@@ -16,8 +16,6 @@
  */
 package org.apache.seata.core.rpc.netty;
 
-import java.util.Arrays;
-import java.util.List;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeoutException;
@@ -93,18 +91,6 @@ public void sendAsyncRequest(Channel channel, Object msg) {
         if (channel == null) {
             throw new RuntimeException("client is not connected");
         }
-        final List<Class> skipSendClassList = Arrays.asList();
-        RpcContext rpcContext = ChannelManager.getContextFromIdentified(channel);
-        String version = rpcContext.getVersion();
-        String channelVersion = Version.getChannelVersion(channel);
-        // todo 过滤发送，但这个version好像不对？
-        boolean aboveV0 = Version.isAboveOrEqualVersion071(version);
-        for (Class aClass : skipSendClassList) {
-            if (aClass.isAssignableFrom(msg.getClass())&&!aboveV0) {
-                return;
-            }
-        }
-
         RpcMessage rpcMessage = buildRequestMessage(msg, ProtocolConstants.MSGTYPE_RESQUEST_ONEWAY);
         super.sendAsync(channel, rpcMessage);
     }