Fix alibaba Rpc compact

AlbumenJ · Jun 21, 2023 · 05eb220 · 05eb220
1 parent 9577d46
commit 05eb220
Show file tree

Hide file tree

Showing 2 changed files with 25 additions and 1 deletion.
diff --git a/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/RpcContext.java b/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/RpcContext.java
@@ -37,6 +37,7 @@
 import java.util.concurrent.FutureTask;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
+import java.util.stream.Collectors;
 
 @Deprecated
 public class RpcContext {
@@ -320,6 +321,25 @@ public boolean isClientSide() {
         return isConsumerSide();
     }
 
+    @Deprecated
+    public Invoker<?> getInvoker() {
+        org.apache.dubbo.rpc.Invoker<?> invoker = newRpcContext.getInvoker();
+        if (invoker == null) {
+            return null;
+        }
+        return new Invoker.CompatibleInvoker<>(invoker);
+    }
+
+    @Deprecated
+    public List<Invoker<?>> getInvokers() {
+        List<org.apache.dubbo.rpc.Invoker<?>> invokers = newRpcContext.getInvokers();
+        if (CollectionUtils.isEmpty(invokers)) {
+            return Collections.emptyList();
+        }
+        return invokers.stream()
+            .map(Invoker.CompatibleInvoker::new)
+            .collect(Collectors.toList());
+    }
     /**
      * Async invocation. Timeout will be handled even if <code>Future.get()</code> is not called.
      *

diff --git a/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/RpcException.java b/dubbo-compatible/src/main/java/com/alibaba/dubbo/rpc/RpcException.java
@@ -19,7 +19,7 @@
 
 @Deprecated
 public class RpcException extends org.apache.dubbo.rpc.RpcException {
-    
+
     public RpcException() {
         super();
     }
@@ -51,4 +51,8 @@ public RpcException(int code, String message) {
     public RpcException(int code, Throwable cause) {
         super(code, cause);
     }
+
+    public boolean isForbidded() {
+        return isForbidden();
+    }
 }